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
5 changes: 5 additions & 0 deletions contributing-docs/30_new_language_sdk.rst
Original file line number Diff line number Diff line change
Expand Up @@ -409,6 +409,11 @@ authored in the target language. An SDK declares each one independently.
The SDK can execute a task declared in a Python Dag with the ``@task.stub``
decorator. This is the primary execution path for every Language SDK.

``taskflow-binding`` (MUST)
Arguments bound to a ``@task.stub`` target in the Python TaskFlow Dag — literal values
and upstream XCom results alike — are delivered to the task function's parameters at
runtime.

``task-logging`` (MUST)
The SDK forwards the task's log output — stdout / stderr and any structured log
records — to the supervisor over the ``--logs`` socket, so it surfaces in the task
Expand Down
1 change: 1 addition & 0 deletions go-sdk/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -302,6 +302,7 @@ prek hook regenerate it.
| state: `removed` | MAY | ✓ | 3.3 | |
| **Runtime capabilities** | | | | |
| capability: `mixed-lang-stub-target` | MUST | ✓ | 3.3 | @task.stub |
| capability: `taskflow-binding` | MUST | ✗ | – | bind @task.stub literal/XCom args to the native handler |
| capability: `task-logging` | MUST | ✓ | 3.3 | slog records streamed over the logs socket |
| capability: `xcom-read-write` | MUST | ✓ | 3.3 | PushXCom / GetXCom |
| capability: `connection-read` | MUST | ✓ | 3.3 | GetConnection |
Expand Down
3 changes: 3 additions & 0 deletions go-sdk/capabilities.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,9 @@ capabilities:
supported: true
since: "3.3"
note: "@task.stub"
taskflow-binding:
supported: false
note: "bind @task.stub literal/XCom args to the native handler"
task-logging:
supported: true
since: "3.3"
Expand Down
1 change: 1 addition & 0 deletions java-sdk/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -605,6 +605,7 @@ prek hook regenerate it.
| state: `removed` | MAY | ✓ | 3.3 | |
| **Runtime capabilities** | | | | |
| capability: `mixed-lang-stub-target` | MUST | ✓ | 3.3 | @task.stub |
| capability: `taskflow-binding` | MUST | ✗ | – | bind @task.stub literal/XCom args to the native handler |
| capability: `task-logging` | MUST | ✓ | 3.3 | SLF4J + JPL bridged to the task log |
| capability: `xcom-read-write` | MUST | ✓ | 3.3 | |
| capability: `connection-read` | MUST | ✓ | 3.3 | |
Expand Down
3 changes: 3 additions & 0 deletions java-sdk/capabilities.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,9 @@ capabilities:
supported: true
since: "3.3"
note: "@task.stub"
taskflow-binding:
supported: false
note: "bind @task.stub literal/XCom args to the native handler"
task-logging:
supported: true
since: "3.3"
Expand Down
1 change: 1 addition & 0 deletions java-sdk/sdk/module.md
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@ meaning of each dimension is defined in the
| state: `removed` | MAY | ✓ | 3.3 | |
| **Runtime capabilities** | | | | |
| capability: `mixed-lang-stub-target` | MUST | ✓ | 3.3 | @task.stub |
| capability: `taskflow-binding` | MUST | ✗ | – | bind @task.stub literal/XCom args to the native handler |
| capability: `task-logging` | MUST | ✓ | 3.3 | SLF4J + JPL bridged to the task log |
| capability: `xcom-read-write` | MUST | ✓ | 3.3 | |
| capability: `connection-read` | MUST | ✓ | 3.3 | |
Expand Down
1 change: 1 addition & 0 deletions scripts/ci/prek/lang_sdk_compat_matrix.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,7 @@ class Capability(NamedTuple):
# whole Dag in the target language and are gated by NATIVE_DAG_GATE (except the gate itself).
CAPABILITY_DIMENSIONS: list[Capability] = [
Capability("mixed-lang-stub-target", "MUST", "runtime", False),
Capability("taskflow-binding", "MUST", "runtime", False),
Capability("task-logging", "MUST", "runtime", False),
Capability("xcom-read-write", "MUST", "runtime", False),
Capability("connection-read", "MUST", "runtime", False),
Expand Down
1 change: 1 addition & 0 deletions ts-sdk/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -245,6 +245,7 @@ Do not edit the table by hand. Update the manifest and run the `update-ts-sdk-re
| state: `removed` | MAY | ✓ | 3.4 | |
| **Runtime capabilities** | | | | |
| capability: `mixed-lang-stub-target` | MUST | ✓ | 3.4 | @task.stub |
| capability: `taskflow-binding` | MUST | ✗ | – | bind @task.stub literal/XCom args to the native handler |
| capability: `task-logging` | MUST | ✓ | 3.4 | structured records over the log socket |
| capability: `xcom-read-write` | MUST | ✓ | 3.4 | getXCom / setXCom |
| capability: `connection-read` | MUST | ✓ | 3.4 | getConnection |
Expand Down
3 changes: 3 additions & 0 deletions ts-sdk/capabilities.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,9 @@ capabilities:
supported: true
since: "3.4"
note: "@task.stub"
taskflow-binding:
supported: false
note: "bind @task.stub literal/XCom args to the native handler"
task-logging:
supported: true
since: "3.4"
Expand Down
Loading