kaxil commented on code in PR #68390:
URL: https://github.com/apache/airflow/pull/68390#discussion_r3397736470
##########
airflow-core/docs/core-concepts/executor/index.rst:
##########
@@ -271,20 +271,17 @@ Example:
ExecuteTask(
token="mock",
- ti=TaskInstance(
+ ti=TaskInstanceDTO(
id=UUID("4d828a62-a417-4936-a7a6-2b3fabacecab"),
task_id="mock",
dag_id="mock",
run_id="mock",
try_number=1,
+ dag_version_id=UUID("4d828a62-a417-4936-a7a6-2b3fabacecab"),
map_index=-1,
pool_slots=1,
queue="default",
priority_weight=1,
- executor_config=None,
Review Comment:
Restored `executor_config` in 3d48d40bc9 -- still on the DTO, and it's the
one optional an executor author actually consumes. Left the rest out
deliberately: `parent_context_carrier` no longer exists on the model (this PR
removes it -- no readers or writers), `context_carrier` is
scheduler-written/worker-read tracing plumbing an executor never touches, and
`queued_dttm` was never a field on the workload model at all -- the old example
passed it and pydantic silently ignored it (the old example also omitted the
now-required `dag_version_id`).
--
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]
