You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ds...@apache.org on 2022/07/22 16:03:20 UTC
[airflow] branch main updated: Dataset-triggered dag runs should have the right DagRunType (#25237)
This is an automated email from the ASF dual-hosted git repository.
dstandish 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 d85cd3db4c Dataset-triggered dag runs should have the right DagRunType (#25237)
d85cd3db4c is described below
commit d85cd3db4cc622821348695dd5cef424ce37b0d8
Author: Daniel Standish <15...@users.noreply.github.com>
AuthorDate: Fri Jul 22 09:03:01 2022 -0700
Dataset-triggered dag runs should have the right DagRunType (#25237)
---
airflow/models/dagrun.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py
index 646beb3222..64c27303a1 100644
--- a/airflow/models/dagrun.py
+++ b/airflow/models/dagrun.py
@@ -703,7 +703,7 @@ class DagRun(Base, LoggingMixin):
dag = row.dag
if dag.schedule_on:
dag.create_dagrun(
- run_type=DagRunType.MANUAL,
+ run_type=DagRunType.DATASET_TRIGGERED,
run_id=self.generate_run_id(
DagRunType.DATASET_TRIGGERED, execution_date=timezone.utcnow()
),