[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r528473691 ## File path: airflow/operators/dagrun_operator.py ## @@ -126,3 +144,22 @@ def execute(self, context: Dict): dag.clear(start_date=self.

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r521699808 ## File path: airflow/operators/dagrun_operator.py ## @@ -55,6 +57,14 @@ class TriggerDagRunOperator(BaseOperator): When reset_dag_run=False an

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r521699461 ## File path: airflow/operators/dagrun_operator.py ## @@ -55,6 +57,14 @@ class TriggerDagRunOperator(BaseOperator): When reset_dag_run=False an

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r521698535 ## File path: airflow/operators/dagrun_operator.py ## @@ -126,3 +144,22 @@ def execute(self, context: Dict): dag.clear(start_date=self.

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r521694146 ## File path: airflow/operators/dagrun_operator.py ## @@ -126,3 +144,22 @@ def execute(self, context: Dict): dag.clear(start_date=self.

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r521693421 ## File path: airflow/operators/dagrun_operator.py ## @@ -126,3 +144,22 @@ def execute(self, context: Dict): dag.clear(start_date=self.

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r520807862 ## File path: airflow/operators/dagrun_operator.py ## @@ -126,3 +148,58 @@ def execute(self, context: Dict): dag.clear(start_date=self.

[GitHub] [airflow] kukigai commented on a change in pull request #12126: Wait option for dagrun operator

kukigai commented on a change in pull request #12126: URL: https://github.com/apache/airflow/pull/12126#discussion_r518871327 ## File path: airflow/operators/dagrun_operator.py ## @@ -126,3 +148,58 @@ def execute(self, context: Dict): dag.clear(start_date=self.