MUKUL GARG
03/22/2023, 12:15 PMdagster._core.errors.DagsterSubprocessError: During celery execution errors occurred in workers:
[test_dict]: dagster._serdes.errors.DeserializationError: Deserialized object was not expected type <class 'dagster._core.events.DagsterEvent'>, got <class 'dict'>
Stack Trace:
File "/usr/local/lib/python3.9/site-packages/dagster_celery/core_execution_loop.py", line 84, in core_celery_execution_loop
step_events = result.get()
File "/usr/local/lib/python3.9/site-packages/celery/result.py", line 220, in get
self.maybe_throw(callback=callback)
File "/usr/local/lib/python3.9/site-packages/celery/result.py", line 336, in maybe_throw
self.throw(value, self._to_remote_traceback(tb))
File "/usr/local/lib/python3.9/site-packages/celery/result.py", line 329, in throw
self.on_ready.throw(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/vine/promises.py", line 234, in throw
reraise(type(exc), exc, tb)
File "/usr/local/lib/python3.9/site-packages/vine/utils.py", line 30, in reraise
raise value
File "/usr/local/lib/python3.9/site-packages/dagster/_core/execution/api.py", line 990, in pipeline_execution_iterator
for event in pipeline_context.executor.execute(pipeline_context, execution_plan):
File "/usr/local/lib/python3.9/site-packages/dagster_celery/core_execution_loop.py", line 164, in core_celery_execution_loop
raise DagsterSubprocessError(