dstandish commented on code in PR #43936:
URL: https://github.com/apache/airflow/pull/43936#discussion_r1849112902
##########
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:
Bit confused.
> The issue with reschedule is getting duplicate calls to listener, with all
parameters the same, besides queued_datetime. This causes duplicate OL start
events with same run_id, which is against OL spec
Can you expand on this a bit. what do you mean "the issue with reschedule"?
i'm not sure which issue or scenario you're referring to.
--
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]
