guan404ming commented on code in PR #61833:
URL: https://github.com/apache/airflow/pull/61833#discussion_r2813134371
##########
airflow-core/src/airflow/jobs/scheduler_job_runner.py:
##########
@@ -2060,6 +2082,16 @@ def _create_dag_runs_asset_triggered(
)
continue
+ if (
+ dag_model.allowed_run_types is not None
+ and DagRunType.ASSET_TRIGGERED.value not in
dag_model.allowed_run_types
+ ):
+ self.log.warning(
+ "Dag does not allow asset-triggered runs; skipping",
Review Comment:
Make sense to me, just moved to the parse time check.
--
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]
