mobuchowski commented on code in PR #43936:
URL: https://github.com/apache/airflow/pull/43936#discussion_r1848075020
##########
providers/src/airflow/providers/dbt/cloud/utils/openlineage.py:
##########
@@ -156,6 +156,8 @@ async def get_artifacts_for_steps(steps, artifacts):
task_id=operator.task_id,
logical_date=_get_logical_date(task_instance),
try_number=_get_try_number(task_instance),
+ queued_dttm=task_instance.queued_dttm,
Review Comment:
In this case, I mean two things: as would not change _during_ run on the
worker - and will change when the task gets rescheduled. I've seen that to be
true - do you think it's not?
As for the thinking, it was the only TI param I've seen changing with each
reschedule of mode=reschedule sensors - I need to distinguish between different
runs of those.
--
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]
