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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
