Spencer Guy
07/05/2023, 10:35 PMCopy
dagster._core.errors.ScheduleExecutionError: Error occurred during the evaluation of schedule graph_daily_swaps_schedule
File "/opt/conda/envs/dataeng/lib/python3.10/site-packages/dagster/_grpc/impl.py", line 288, in get_external_schedule_execution
return schedule_def.evaluate_tick(schedule_context)
File "/opt/conda/envs/dataeng/lib/python3.10/site-packages/dagster/_core/definitions/schedule_definition.py", line 506, in evaluate_tick
result = list(ensure_gen(execution_fn(context)))
File "/opt/conda/envs/dataeng/lib/python3.10/site-packages/dagster/_core/definitions/decorators/schedule_decorator.py", line 136, in _wrapped_fn
with user_code_error_boundary(
File "/opt/conda/envs/dataeng/lib/python3.10/contextlib.py", line 153, in __exit__
self.gen.throw(typ, value, traceback)
File "/opt/conda/envs/dataeng/lib/python3.10/site-packages/dagster/_core/errors.py", line 195, in user_code_error_boundary
raise error_cls(
The above exception was caused by the following exception:
TypeError: RunRequest.__new__() got an unexpected keyword argument 'partition_key'
File "/opt/conda/envs/dataeng/lib/python3.10/site-packages/dagster/_core/errors.py", line 188, in user_code_error_boundary
yield
File "/opt/conda/envs/dataeng/lib/python3.10/site-packages/dagster/_core/definitions/decorators/schedule_decorator.py", line 163, in _wrapped_fn
yield from cast(RunRequestIterator, ensure_gen(result))
File "/opt/dagster/app/jobs/swaps_jobs.py", line 54, in graph_daily_swaps_schedule
yield RunRequest(run_key=x, partition_key=x)