Will Tyree
02/15/2023, 11:16 PMTypeError: SqlEventLogStorage._get_asset_entry_values() missing 1 required positional argument: 'has_asset_key_index_cols'
owen
02/15/2023, 11:28 PMWill Tyree
02/15/2023, 11:32 PMowen
02/15/2023, 11:32 PMWill Tyree
02/15/2023, 11:33 PMWill Tyree
02/15/2023, 11:34 PMdagster._core.errors.DagsterExecutionStepExecutionError: Error occurred while executing op "load_raw_datasets_from_s3":File "/usr/local/lib/python3.10/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 "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/plan/execute_step.py", line 382, in core_dagster_event_sequence_for_step
for user_event in check.generator(
File "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/plan/execute_step.py", line 94, in _step_output_error_checked_user_event_sequence
for user_event in user_event_sequence:
File "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/plan/compute.py", line 177, in execute_core_compute
for step_output in _yield_compute_results(step_context, inputs, compute_fn):
File "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/plan/compute.py", line 145, in _yield_compute_results
for event in iterate_with_context(
File "/usr/local/lib/python3.10/site-packages/dagster/_utils/__init__.py", line 467, in iterate_with_context
with context_fn():
File "/usr/local/lib/python3.10/contextlib.py", line 153, in exit
self.gen.throw(typ, value, traceback)
File "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/plan/utils.py", line 85, in op_execution_error_boundary
raise error_cls(
The above exception was caused by the following exception:
TypeError: SqlEventLogStorage._get_asset_entry_values() missing 1 required positional argument: 'has_asset_key_index_cols'
File "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/plan/utils.py", line 55, in op_execution_error_boundary
yield
File "/usr/local/lib/python3.10/site-packages/dagster/_utils/__init__.py", line 469, in iterate_with_context
next_output = next(iterator)
File "/resoptpipelines/preprocessing/ingest.py", line 86, in load_raw_datasets_from_s3
context.resources.materialize.pandas_dataframe(context, run_config.path, df, "Raw")
File "/resoptpipelines/resources/asset_materializer.py", line 36, in pandas_dataframe
runcontext.log_event(
File "/usr/local/lib/python3.10/site-packages/dagster/_core/execution/context/compute.py", line 512, in log_event
DagsterEvent.asset_materialization(
File "/usr/local/lib/python3.10/site-packages/dagster/_core/events/__init__.py", line 901, in asset_materialization
return DagsterEvent.from_step(
File "/usr/local/lib/python3.10/site-packages/dagster/_core/events/__init__.py", line 413, in from_step
log_step_event(step_context, event)
File "/usr/local/lib/python3.10/site-packages/dagster/_core/events/__init__.py", line 292, in log_step_event
step_context.log.log_dagster_event(
File "/usr/local/lib/python3.10/site-packages/dagster/_core/log_manager.py", line 384, in log_dagster_event
self.log(level=level, msg=msg, extra={DAGSTER_META_KEY: dagster_event})
File "/usr/local/lib/python3.10/site-packages/dagster/_core/log_manager.py", line 399, in log
self._log(level, msg, args, **kwargs)
File "/usr/local/lib/python3.10/logging/__init__.py", line 1624, in _log
self.handle(record)
File "/usr/local/lib/python3.10/logging/__init__.py", line 1634, in handle
self.callHandlers(record)
File "/usr/local/lib/python3.10/logging/__init__.py", line 1696, in callHandlers
hdlr.handle(record)
File "/usr/local/lib/python3.10/logging/__init__.py", line 968, in handle
self.emit(record)
File "/usr/local/lib/python3.10/site-packages/dagster/_core/log_manager.py", line 265, in emit
handler.handle(dagster_record)
File "/usr/local/lib/python3.10/logging/__init__.py", line 968, in handle
self.emit(record)
File "/usr/local/lib/python3.10/site-packages/dagster/_core/instance/__init__.py", line 181, in emit
self._instance.handle_new_event(event)
File "/usr/local/lib/python3.10/site-packages/dagster/_core/instance/__init__.py", line 1772, in handle_new_event
self._event_storage.store_event(event)
File "/usr/local/lib/python3.10/site-packages/dagster_postgres/event_log/event_log.py", line 178, in store_event
self.store_asset_event(event)
File "/usr/local/lib/python3.10/site-packages/dagster_postgres/event_log/event_log.py", line 222, in store_asset_event
values = self._get_asset_entry_values(event, self.has_secondary_index(ASSET_KEY_INDEX_COLS))owen
02/15/2023, 11:36 PMdagster_postgres
version is different from your dagster
verison?Will Tyree
02/15/2023, 11:36 PMWill Tyree
02/15/2023, 11:40 PMowen
02/15/2023, 11:41 PM0.17.18
(really all the library dependencies should be)owen
02/15/2023, 11:41 PM1.1.14
would also workWill Tyree
02/15/2023, 11:42 PM