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 2022/02/23 16:50:50 UTC

[GitHub] [airflow] avkirilishin commented on a change in pull request #21684: Add dependency to the running_deps

avkirilishin commented on a change in pull request #21684:
URL: https://github.com/apache/airflow/pull/21684#discussion_r813102311



##########
File path: airflow/ti_deps/deps/exec_date_after_start_date_dep.py
##########
@@ -28,15 +28,19 @@ class ExecDateAfterStartDateDep(BaseTIDep):
 
     @provide_session
     def _get_dep_statuses(self, ti, session, dep_context):
-        if ti.task.start_date and ti.execution_date < ti.task.start_date:
+        if ti.task.start_date and ti.get_dagrun(session=session).execution_date < ti.task.start_date:

Review comment:
       After your commit https://github.com/apache/airflow/commit/80ae70c3d0f6109e974d50726da5a44e58d1b674 DagRun must be loaded first (via get_dagrun) or TaskInstance's execution_date would be None




-- 
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