dabla commented on code in PR #55068:
URL: https://github.com/apache/airflow/pull/55068#discussion_r2802747188
##########
airflow-core/src/airflow/executors/workloads.py:
##########
@@ -203,6 +203,9 @@ class RunTrigger(BaseModel):
type: Literal["RunTrigger"] = Field(init=False, default="RunTrigger")
+ dag_data: dict | None = None
Review Comment:
As discussed on slack, I've added a check to determine when we need the
whole serialized Dag, only passing the serialized task would be a more
challenging change and also templated fields could rely on other stuff than
just the task itself so it would possibly break anyway so at the moment we
agreed to pass the full serialized DAg but only when it's need, meaning if
trigger is associated to a task containing an operator with start from trigger
and actually has templated fields (most will) but also has start trigger args
specified.
--
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]
