Guy McCombe
12/19/2022, 4:47 PMload_assets_from_airbyte_instance
function, is there a way to get dagster to refresh the assets it’s loading from the instance? keanu thanksrex
12/19/2022, 4:49 PMben
12/19/2022, 4:49 PMGuy McCombe
12/19/2022, 4:50 PMben
12/19/2022, 4:51 PMGuy McCombe
12/19/2022, 4:52 PMben
12/19/2022, 4:54 PMGuy McCombe
12/19/2022, 4:55 PMdagster._core.errors.DagsterStepOutputNotFoundError: Core compute for op "airbyte_sync_54095" did not return an output for non-optional output "contacts"
Stack Trace:
File "/usr/local/lib/python3.7/site-packages/dagster/_core/execution/plan/execute_plan.py", line 225, in dagster_event_sequence_for_step
for step_event in check.generator(step_events):
, File "/usr/local/lib/python3.7/site-packages/dagster/_core/execution/plan/execute_step.py", line 361, in core_dagster_event_sequence_for_step
_step_output_error_checked_user_event_sequence(step_context, user_event_sequence)
, File "/usr/local/lib/python3.7/site-packages/dagster/_core/execution/plan/execute_step.py", line 156, in _step_output_error_checked_user_event_sequence
output_name=step_output_def.name,
ben
12/19/2022, 5:01 PMGuy McCombe
12/19/2022, 5:01 PMben
12/19/2022, 6:46 PMconnection_filter
to load_assets_from_airbyte_instance
, you can give it a no-op lambda _: True
, which should be enough to change the cache key.Guy McCombe
12/19/2022, 6:51 PMben
12/19/2022, 6:57 PMinspect.getsource()
of the function, so changing its definition (in a no-op manner) should be enoughGuy McCombe
12/19/2022, 7:08 PMben
12/19/2022, 7:09 PMGuy McCombe
12/19/2022, 7:09 PM