Skip to content

Workflow service not creating all the checkpoints in a workflow life cycle

Issue:

Workflow service is creating only two checkpoints for a workflow.

Expected Behaviour:

It should create all the checkpoints from workflow lifecycle

Logs from executor

2024-08-06T12:26:25.441+0530    INFO    duo_workflow_executor/main.go:61        Starting client {"version": "", "server": "localhost:50052"}
2024-08-06T12:26:25.842+0530    DEBUG   duo_workflow_executor/main.go:80        Received action {"action": "runHTTPRequest:{method:\"GET\" path:\"/api/v4/ai/duo_workflows/workflows/10/checkpoints\"}"}
2024-08-06T12:26:26.018+0530    DEBUG   duo_workflow_executor/main.go:107       Action result   {"result": "[]"}


2024-08-06T12:26:26.022+0530    DEBUG   duo_workflow_executor/main.go:80        Received action {"action": "runHTTPRequest:{method:\"POST\" path:\"/api/v4/ai/duo_workflows/workflows/10/checkpoints\" body:\"{\\\"thread_id\\\": \\\"10\\\", \\\"thread_ts\\\": \\\"1ef53c0f-fae5-6272-bfff-58dc258bca70\\\", \\\"parent_ts\\\": null, \\\"checkpoint\\\": {\\\"v\\\": 1, \\\"ts\\\": \\\"2024-08-06T06:56:26.021506+00:00\\\", \\\"id\\\": \\\"1ef53c0f-fae5-6272-bfff-58dc258bca70\\\", \\\"channel_values\\\": {\\\"conversation_history\\\": {}, \\\"__start__\\\": {\\\"plan\\\": {\\\"steps\\\": []}, \\\"status\\\": \\\"Not Started\\\", \\\"conversation_history\\\": {}}}, \\\"channel_versions\\\": {\\\"__start__\\\": 1}, \\\"versions_seen\\\": {}, \\\"pending_sends\\\": []}, \\\"metadata\\\": {\\\"source\\\": \\\"input\\\", \\\"step\\\": -1, \\\"writes\\\": {\\\"plan\\\": {\\\"steps\\\": []}, \\\"status\\\": \\\"Not Started\\\", \\\"conversation_history\\\": {}}}}\"}"}

2024-08-06T12:26:26.075+0530    DEBUG   duo_workflow_executor/main.go:107       Action result   {"result": "{\"id\":21,\"thread_ts\":\"1ef53c0f-fae5-6272-bfff-58dc258bca70\",\"parent_ts\":null,\"checkpoint\":{\"v\":1,\"ts\":\"2024-08-06T06:56:26.021506+00:00\",\"id\":\"1ef53c0f-fae5-6272-bfff-58dc258bca70\",\"channel_values\":{\"conversation_history\":{},\"__start__\":{\"plan\":{\"steps\":[]},\"status\":\"Not Started\",\"conversation_history\":{}}},\"channel_versions\":{\"__start__\":1},\"versions_seen\":{},\"pending_sends\":[]},\"metadata\":{\"source\":\"input\",\"step\":-1,\"writes\":{\"plan\":{\"steps\":[]},\"status\":\"Not Started\",\"conversation_history\":{}}}}"}


2024-08-06T12:26:26.076+0530    DEBUG   duo_workflow_executor/main.go:80        Received action {"action": "runHTTPRequest:{method:\"POST\" path:\"/api/v4/ai/duo_workflows/workflows/10/checkpoints\" body:\"{\\\"thread_id\\\": \\\"10\\\", \\\"thread_ts\\\": \\\"1ef53c0f-fae8-6ac6-8000-0684555988ce\\\", \\\"parent_ts\\\": \\\"1ef53c0f-fae5-6272-bfff-58dc258bca70\\\", \\\"checkpoint\\\": {\\\"v\\\": 1, \\\"ts\\\": \\\"2024-08-06T06:56:26.022968+00:00\\\", \\\"id\\\": \\\"1ef53c0f-fae8-6ac6-8000-0684555988ce\\\", \\\"channel_values\\\": {\\\"plan\\\": {\\\"steps\\\": []}, \\\"status\\\": \\\"Not Started\\\", \\\"conversation_history\\\": {}, \\\"start:planning\\\": \\\"__start__\\\"}, \\\"channel_versions\\\": {\\\"__start__\\\": 2, \\\"plan\\\": 2, \\\"status\\\": 2, \\\"conversation_history\\\": 2, \\\"start:planning\\\": 2}, \\\"versions_seen\\\": {\\\"__start__\\\": {\\\"__start__\\\": 1}, \\\"planning\\\": {}, \\\"update_plan\\\": {}, \\\"planning_supervisor\\\": {}, \\\"execution\\\": {}, \\\"execution_tools\\\": {}, \\\"execution_supervisor\\\": {}, \\\"execution_handover\\\": {}}, \\\"pending_sends\\\": []}, \\\"metadata\\\": {\\\"source\\\": \\\"loop\\\", \\\"step\\\": 0, \\\"writes\\\": null}}\"}"}

2024-08-06T12:26:26.103+0530    DEBUG   duo_workflow_executor/main.go:107       Action result   {"result": "{\"id\":22,\"thread_ts\":\"1ef53c0f-fae8-6ac6-8000-0684555988ce\",\"parent_ts\":\"1ef53c0f-fae5-6272-bfff-58dc258bca70\",\"checkpoint\":{\"v\":1,\"ts\":\"2024-08-06T06:56:26.022968+00:00\",\"id\":\"1ef53c0f-fae8-6ac6-8000-0684555988ce\",\"channel_values\":{\"plan\":{\"steps\":[]},\"status\":\"Not Started\",\"conversation_history\":{},\"start:planning\":\"__start__\"},\"channel_versions\":{\"__start__\":2,\"plan\":2,\"status\":2,\"conversation_history\":2,\"start:planning\":2},\"versions_seen\":{\"__start__\":{\"__start__\":1},\"planning\":{},\"update_plan\":{},\"planning_supervisor\":{},\"execution\":{},\"execution_tools\":{},\"execution_supervisor\":{},\"execution_handover\":{}},\"pending_sends\":[]},\"metadata\":{\"source\":\"loop\",\"step\":0,\"writes\":null}}"}


2024-08-06T12:26:42.443+0530    DEBUG   duo_workflow_executor/main.go:80        Received action {"action": "runWriteFile:{filepath:\"hello_world.sh\" contents:\"#!/bin/bash\\necho \\\"Hello world\\\"\"}"}
2024-08-06T12:26:42.444+0530    DEBUG   duo_workflow_executor/main.go:107       Action result   {"result": "File written successfully"}
2024-08-06T12:26:45.946+0530    DEBUG   duo_workflow_executor/main.go:80        Received action {"action": "runReadFile:{filepath:\"hello_world.sh\"}"}
2024-08-06T12:26:45.947+0530    DEBUG   duo_workflow_executor/main.go:107       Action result   {"result": "#!/bin/bash\necho \"Hello world\""}
Edited by Surabhi Suman