search

wayfair-incubator / dagger

A simple Python-based distributed workflow engine
https://wayfair-incubator.github.io/dagger/latest
MIT License
54 stars 5 forks source link

Error while processing listener stack #41

Closed patkivikram closed 1 year ago

patkivikram commented 1 year ago

Description

Seeing the following Exception in the stack 2023-05-01 11:06:08 [9] [ERROR] faust.agents.actor [^-----Agent*: dagger.tasks.tas[.]process_event]: Crashed reason=UnboundLocalError("local variable 'value' referenced before assignment") Traceback (most recent call last): File "/pyenv/versions/fos-inbound/lib/python3.9/site-packages/faust/agents/agent.py", line 674, in _execute_actor await coro File "/pyenv/versions/fos-inbound/lib/python3.9/site-packages/dagger/tasks/task.py", line 916, in process_event await self.process_event_helper(event) File "/pyenv/versions/fos-inbound/lib/python3.9/site-packages/dagger/tasks/task.py", line 806, in process_event_helper async for workflow_instance, task_instance in self.app._get_tasks_by_correlatable_key( File "/pyenv/versions/fos-inbound/lib/python3.9/site-packages/dagger/service/services.py", line 400, in _get_tasks_by_correlatable_key workflow_instance = await self._invoke_store_get_value_for_key_with_timer( File "/pyenv/versions/fos-inbound/lib/python3.9/site-packages/dagger/service/services.py", line 706, in _invoke_store_get_value_for_key_with_timer

Affected Version

0.2.1

Checklist