https://dagster.io/ logo
#ask-community
Title
# ask-community
m

MUKUL GARG

03/22/2023, 12:15 PM
Hi Team, I am getting the below error while running the job with celeryK8slauncher - I am using dagster 1.2.2
dagster._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(
2 Views