roadrunner
roadrunner copied to clipboard
[🧹 CHORE]: handle worker stopped error in the OnWorkflowStarted loop when flushing the queue
No duplicates 🥲.
- [x] I have searched for a similar issue.
What should be improved or cleaned up?
ERROR temporal Workflow panic {"Namespace": "default", "TaskQueue": "default", "WorkerID": "default:c910107e-50c7-48b1-bd91-dc06f7c897fd", "WorkflowType": "SimpleWorkflow", "WorkflowID": "4a38c2d9-f772-4642-b030-eb50b7cbbb99", "RunID": "0196a501-4f5a-7b82-b29b-37ad43f0c3a0", "Attempt": 1, "Error": "static_pool_exec: Workers watcher stopped:\n\tstatic_pool_exec:\n\tworker_watcher_get_free_worker", "StackTrace": "process event for default [panic]:\ngithub.com/temporalio/roadrunner-temporal/v5/aggregatedpool.(*Workflow).OnWorkflowTaskStarted(0xc0018877a0, 0x3c?)\n\tgithub.com/temporalio/roadrunner-temporal/[email protected]/aggregatedpool/workflow.go:312 +0x3e5\ngo.temporal.io/sdk/internal.(*workflowExecutionEventHandlerImpl).ProcessEvent(0xc001fef140, 0xc001458990, 0x20?, 0x1)\n\tgo.temporal.io/[email protected]/internal/internal_event_handlers.go:1218 +0x30a\ngo.temporal.io/sdk/internal.(*workflowExecutionContextImpl).ProcessWorkflowTask(0xc0019c8b40, 0xc00031fad0)\n\tgo.temporal.io/[email protected]/internal/internal_task_handlers.go:1182 +0x1a8a\ngo.temporal.io/sdk/internal.(*workflowTaskHandlerImpl).ProcessWorkflowTask(0xc000123500, 0xc001e0f170, 0xc001f281e0, 0xc001e763c0)\n\tgo.temporal.io/[email protected]/internal/internal_task_handlers.go:929 +0x59e\ngo.temporal.io/sdk/internal.(*workflowTaskPoller).processWorkflowTask(0xc0001fc780, 0xc001e0f170)\n\tgo.temporal.io/[email protected]/internal/internal_task_pollers.go:424 +0x3db\ngo.temporal.io/sdk/internal.(*workflowTaskPoller).ProcessTask(0xc0001fc780, {0x1f67f40, 0xc001e0f170})\n\tgo.temporal.io/[email protected]/internal/internal_task_pollers.go:372 +0x205\ngo.temporal.io/sdk/internal.(*baseWorker).processTaskAsync.func1()\n\tgo.temporal.io/[email protected]/internal/internal_worker_base.go:453 +0x12f\ncreated by go.temporal.io/sdk/internal.(*baseWorker).processTaskAsync in goroutine 136\n\tgo.temporal.io/[email protected]/internal/internal_worker_base.go:432 +0x8c"}