dstandish commented on code in PR #43936:
URL: https://github.com/apache/airflow/pull/43936#discussion_r1848712166
##########
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:
We recently added a feature, when a task gets stuck in queued, then we may
set it back to scheduled and queue it again. The queued time is not part of
what defines a TI so i don't see a reason to include it here. Did you have any
particular reason that you thought it was _needed_? (Beyond a reason you think
it _wouldn't hurt_)
--
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]
