Leon Kozlowski
03/03/2023, 8:29 PMallow_failure
utility - is there something similar to invoke only when an upstream task fails?
My use case is a flow running dbt models, I want to run failed models when the original task failsLeon Kozlowski
03/03/2023, 8:30 PMLeon Kozlowski
03/03/2023, 8:33 PMstate = trigger_dbt_cli_command(
command="dbt build -s +tag:mytags+",
**trigger_kwargs,
wait_for=[deps],
)
if state.is_failed():
trigger_dbt_cli_command(
command="dbt build -s +tag:mytags+ result:error+ --defer --state ./targets",
**trigger_kwargs,
wait_for=[allow_failure(state)],
)
Zanie
return_state=True
to that first callZanie