uranusjr commented on code in PR #37888:
URL: https://github.com/apache/airflow/pull/37888#discussion_r1512003186
##########
airflow/jobs/scheduler_job_runner.py:
##########
@@ -1284,9 +1284,17 @@ def _create_dag_runs_dataset_triggered(
events=dataset_events,
)
+ run_conf = {}
+ for item in dataset_events:
+ event: DatasetEvent = item
+ extra: dict | None = event.extra
+ if extra:
+ run_conf.update(extra)
Review Comment:
This feels a bit too heavy-handed, but I like the idea of passing in event
extras as the downstream DAG run parameters. (Should we use conf or params for
this?)
--
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]
