You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/10/31 02:29:49 UTC

[airflow] branch main updated: Improve reset_dag_run description (#26755)

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 6f20d4d324 Improve reset_dag_run description (#26755)
6f20d4d324 is described below

commit 6f20d4d3247e44ea04558226aeeed09bf8379173
Author: Sahil Thapar <sa...@gmail.com>
AuthorDate: Sun Oct 30 19:29:43 2022 -0700

    Improve reset_dag_run description (#26755)
    
    - to clarify this only resets the dag_run and not recreates it
    - and that the dag_run.conf is immutable and cannot be reset
    See discussion #24548 for more details
---
 airflow/operators/trigger_dagrun.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/airflow/operators/trigger_dagrun.py b/airflow/operators/trigger_dagrun.py
index 630ca9c354..0fff9fcfdd 100644
--- a/airflow/operators/trigger_dagrun.py
+++ b/airflow/operators/trigger_dagrun.py
@@ -70,6 +70,8 @@ class TriggerDagRunOperator(BaseOperator):
     :param execution_date: Execution date for the dag (templated).
     :param reset_dag_run: Whether or not clear existing dag run if already exists.
         This is useful when backfill or rerun an existing dag run.
+        This only resets (not recreates) the dag run.
+        Dag run conf is immutable and will not be reset on rerun of an existing dag run.
         When reset_dag_run=False and dag run exists, DagRunAlreadyExists will be raised.
         When reset_dag_run=True and dag run exists, existing dag run will be cleared to rerun.
     :param wait_for_completion: Whether or not wait for dag run completion. (default: False)