amoghrajesh commented on code in PR #76918:
URL: https://github.com/apache/airflow/pull/76918#discussion_r4546360857
##########
providers/dbt/cloud/src/airflow/providers/dbt/cloud/operators/dbt.py:
##########
@@ -94,6 +114,9 @@ class DbtCloudRunJobOperator(BaseOperator):
reading dbt Cloud runs can parse this to link the dbt Cloud run back
to the Airflow task that
triggered it. Note this overwrites the ``trigger_reason``. Defaults to
the
``openlineage.spark_inject_parent_job_info`` config value.
+ :param durable: When ``True`` (the default), the dbt Cloud run id is
persisted to task state before
Review Comment:
Added a "Durable execution" section under "Trigger a dbt Cloud Job". It
covers the retry outcomes, clearing as of #76806 (the Dag run clear also
discards the stored run id, so the fix-then-clear case triggers a new dbt run),
and what keep_task_state does instead.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
