kaxil commented on code in PR #68390:
URL: https://github.com/apache/airflow/pull/68390#discussion_r3396857156
##########
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/taskinstance.py:
##########
@@ -286,6 +286,11 @@ class TaskInstance(BaseModel):
map_index: int = -1
hostname: str | None = None
context_carrier: dict | None = None
+ # Defaults keep hand-built instances (tests, dry runs) valid; the executor
+ # workload always sends the real values.
+ queue: str = "default"
+ pool_slots: int = 1
+ priority_weight: int = 1
Review Comment:
You're right -- the worker only needs `queue` (coordinator routing).
`priority_weight` is only read by the executor's queued-workload sort
(`base_executor.py`) and `pool_slots` only by the edge executor for its
`concurrency_slots` accounting, both before the workload ever leaves the
executor. Updated: only `queue` joins the schema; the other two stay on the
executor-side DTO, serialized as before so older workers that deserialize the
workload with the required-field model keep working.
--
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]
