You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2021/11/22 05:42:17 UTC

[GitHub] [airflow] uranusjr edited a comment on issue #19286: metric: Time after triggering

uranusjr edited a comment on issue #19286:
URL: https://github.com/apache/airflow/issues/19286#issuecomment-975147311


   All `DagRun` instances are populated from `DagRunInfo`. Actually, `DagRunInfo` is already used to populate some fields on `DagModel` that are used to schedule the next DAG run:
   
   https://github.com/apache/airflow/blob/1b89e682a1a04adf2cf5ebb37a453e245a6e7191/airflow/models/dag.py#L2920-L2928
   
   So what we need to do is to pass that information on when the scheduler decides to actually create the next DAG run.
   
   A DAG run is created with `DAG.create_dagrun()`, so you need to add an argument on that function, and change all `create_dagrun()` calls to use that argument. This will allow `DagRun.run_after` to be populated by `DagRunInfo.run_after` and thus in sync.
   
   


-- 
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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org