Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -276,6 +276,9 @@ tracked in [#70523](https://github.com/apache/airflow/issues/70523).
- The mechanism is not private to `@task.stub`: any TaskFlow-shaped operator that sets `is_stub`
gets arg-binding materialization. A stub-flagged operator that is not a `DecoratedOperator` is
recognized as stub-backed but receives no bindings (decision B).
- Core is not the only producer. A language SDK that declares a Dag of its own serializes its tasks
with `is_stub` and writes `_arg_bindings` into the Dag it submits, with no Python operator behind
them, so `_arg_bindings` means "a stub task's captured arguments", not "@task.stub".
- Older clients are unaffected: the version migration strips `arg_bindings`, and the server skips
deriving it for them entirely.

Expand Down
2 changes: 1 addition & 1 deletion airflow-core/src/airflow/serialization/schema.json
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@
"max_active_tis_per_dag": {"type": "integer"},
"max_active_tis_per_dagrun": {"type": "integer"},
"_arg_bindings": {
"$comment": "Only present on @task.stub tasks called with TaskFlow arguments",
"$comment": "Used for mixed-language tasks (the @task.stub operator) or tasks defined in a non-Python SDK Dag",
"type": "array",
"items": { "$ref": "#/definitions/arg_binding" }
}
Expand Down
2 changes: 1 addition & 1 deletion ts-sdk/schema/dag-schema.json
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@
"max_active_tis_per_dag": {"type": "integer"},
"max_active_tis_per_dagrun": {"type": "integer"},
"_arg_bindings": {
"$comment": "Only present on @task.stub tasks called with TaskFlow arguments",
"$comment": "Used for mixed-language tasks (the @task.stub operator) or tasks defined in a non-Python SDK Dag",
"type": "array",
"items": { "$ref": "#/definitions/arg_binding" }
}
Expand Down
Loading