dstandish commented on PR #61420:
URL: https://github.com/apache/airflow/pull/61420#issuecomment-3846993859
so, i decided to go with this which seems it should do basically the same
thing
```
dates = {current_logical_date}
dates.update(
info.logical_date
for info in dag.iter_dagrun_infos_between(start_date, end_date)
if info.logical_date # todo: AIP-76 this will not find anything
where logical date is null
)
run_ids = [dr.run_id for dr in DagRun.find(dag_id=dag.dag_id,
logical_date=dates, session=session)]
```
this feels like it will produce same result.
basically, if the current_logical_date is not aligned, then it would have
faked a data interval for that logical date so that it would end up in the
dates list, which would then be passed to DagRun.find, so that the run_id
passed in originally would be included.
so now i just ensure that no matter what the current logical date ends up
included in the dates list, so the passed-in run id will always be included in
the output. so i think we're good here.
--
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]
