Peter Davidson
02/27/2023, 7:46 AMAn unexpected exception was thrown. Please file an issue.
TypeError: get_upstream_partitions_for_partitions() got an unexpected keyword argument 'dynamic_partitions_store'
File "C:\Users\peter.davidson\venv\v385\lib\site-packages\dagster\_core\execution\plan\execute_plan.py", line 265, in dagster_event_sequence_for_step
for step_event in check.generator(step_events):
File "C:\Users\peter.davidson\venv\v385\lib\site-packages\dagster\_core\execution\plan\execute_step.py", line 344, in core_dagster_event_sequence_for_step
for event_or_input_value in ensure_gen(
File "C:\Users\peter.davidson\venv\v385\lib\site-packages\dagster\_core\execution\plan\inputs.py", line 522, in load_input_object
load_input_context = self.get_load_context(step_context, input_def)
File "C:\Users\peter.davidson\venv\v385\lib\site-packages\dagster\_core\execution\plan\inputs.py", line 475, in get_load_context
return step_context.for_input_manager(
File "C:\Users\peter.davidson\venv\v385\lib\site-packages\dagster\_core\execution\context\system.py", line 614, in for_input_manager
self.asset_partitions_subset_for_input(name)
File "C:\Users\peter.davidson\venv\v385\lib\site-packages\dagster\_core\execution\context\system.py", line 941, in asset_partitions_subset_for_input
return partition_mapping.get_upstream_partitions_for_partitions(
sandy
02/27/2023, 4:51 PMPeter Davidson
02/27/2023, 5:26 PMdynamic_partitions_store: Optional[DynamicPartitionsStore] = None,was addet to the base PartitionMapping class. I just had to add this to the implementation I wrote to allow for this, then it's working again. Took a bit of digging though.
claire
02/27/2023, 5:51 PMPeter Davidson
02/27/2023, 5:54 PM