This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch
jason/core-taskhandler-refactor/06-go-sdk-task-handler-parse
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 78995cf2159 State that a task handler parse answer depends only on the
artifact
omit fb64343c9d8 Go SDK: answer a task handler parse with every handler
omit acf207ebde4 Tidy names, mocks and cases in the Go probe and digest
tests
omit d6f462f00fa Move Go SDK comments back to the code they describe
omit 91307f3fa75 Resolve the probed bundle path and tighten the digest docs
omit e939ac6fe39 Go SDK: take the bundle digests from the staged executable
omit b69ecca8f6d Document the task handler parse for Language SDK authors
omit 84d7d5116f1 Read a Go bundle's stored cache digest without hashing it
omit 7b809900183 Let the Executable coordinator probe a bundle's task
handlers
omit 0ab82445ec9 Go SDK: record integrity and cache digests in bundle
metadata
omit a5c07046389 Go SDK: regenerate genmodels for the named_open binding
omit 90eb57225a3 Go SDK: clarify parse timeout and nested-null docs, test
anyOf
omit 47741c863b2 Go SDK: answer TaskHandlerParseRequest with registered
handlers
omit 6da5481daec Go SDK: describe task handler params with JSON Schema
omit 0d0c1a66281 Go SDK: regenerate genmodels from the supervisor schema
omit f6918d8ecdc Probe a task handler artifact without naming Dags
omit 645a024a749 Close the fake runtime's sockets when its reply is done
omit ba5d137a275 Name the runtime transport test helpers with verbs
omit 59011fc543f Patch with decorators in the runtime transport tests
omit 54ff4e1f46b Hang the fake runtimes without sleeping
omit 59e16139df4 Test that a start failing before the fork closes its
listeners
omit 6360ff7f697 Spec the mocks in the runtime transport and probe tests
omit 70357892782 Import ctypes at the top of the subprocess coordinator
module
omit 34ef146bcf9 Pass the binding mode in the task-handler probe tests
omit f2100f22358 Tidy the runtime transport and the coordinator lookup
omit 775c0dd16f9 Clean up a Lang-SDK runtime parse whose start fails after
the fork
omit 9c95909cd18 Do not exec a Lang-SDK runtime whose parent has already
exited
omit e41925c8a03 Kill what a Lang-SDK runtime leaves behind when it exits
omit beeaafc8745 Read a Lang-SDK runtime's frames without blocking the
parse loop
omit a43ef8a4751 Probe a Lang-SDK artifact for its task handlers
omit 0f5792c18e4 Keep a nested supervised child's standard streams open
omit 3a114b15c0c Make the Dag file processor base generic over its result
omit f5e6690653e Let a subprocess coordinator exec a task-handler parse
runtime
add 69ac8da87fb Bind task handlers only by position or by name
add 6c3f0eda7c9 Regenerate TS SDK supervisor types for the two binding
modes
add 48f58db7caf Describe the two task handler binding modes in the ADRs
add 7e229e82f86 Let a subprocess coordinator exec a task-handler parse
runtime
add 400d08b04d4 Make the Dag file processor base generic over its result
add b3d5f26dcdd Keep a nested supervised child's standard streams open
add 0ab3e095f6d Probe a Lang-SDK artifact for its task handlers
add 6a37b6d6166 Read a Lang-SDK runtime's frames without blocking the
parse loop
add a1782e45de9 Kill what a Lang-SDK runtime leaves behind when it exits
add 9856d8b0cc1 Do not exec a Lang-SDK runtime whose parent has already
exited
add c32ed26aa98 Clean up a Lang-SDK runtime parse whose start fails after
the fork
add 7a7f588a6bc Tidy the runtime transport and the coordinator lookup
add 25a918a97cb Pass the binding mode in the task-handler probe tests
add 8e0f64d7ee3 Import ctypes at the top of the subprocess coordinator
module
add 4acdded53e1 Spec the mocks in the runtime transport and probe tests
add b12cf16c735 Test that a start failing before the fork closes its
listeners
add c1861502159 Hang the fake runtimes without sleeping
add fde3390849a Patch with decorators in the runtime transport tests
add 1206141d55b Name the runtime transport test helpers with verbs
add f1ac0ab61d4 Close the fake runtime's sockets when its reply is done
add eb406929ad3 Probe a task handler artifact without naming Dags
add 7a8bab885bc Build the probe test's params without the dropped required
add faf5e976f0c Go SDK: regenerate genmodels from the supervisor schema
add 9a8627af5d3 Go SDK: describe task handler params with JSON Schema
add 795b97cb9cd Go SDK: answer TaskHandlerParseRequest with registered
handlers
add 9fa167c731c Go SDK: clarify parse timeout and nested-null docs, test
anyOf
add bfadfbe16b6 Go SDK: regenerate genmodels for the named_open binding
add 5dc64b4eef2 Go SDK: record integrity and cache digests in bundle
metadata
add 5f5c3397476 Let the Executable coordinator probe a bundle's task
handlers
add b1f99665ded Read a Go bundle's stored cache digest without hashing it
add 6ef66f078a5 Document the task handler parse for Language SDK authors
add 609c46c0038 Go SDK: take the bundle digests from the staged executable
add de6d01540b6 Resolve the probed bundle path and tighten the digest docs
add 5e38a0ba4ee Move Go SDK comments back to the code they describe
add dd9027215fb Tidy names, mocks and cases in the Go probe and digest
tests
add 8f74493f2be Go SDK: answer a task handler parse with every handler
add 54363fc4a9d State that a task handler parse answer depends only on the
artifact
add dc549f98eb3 Go SDK: declare every lone struct handler as named
add b1151dc3b23 Describe the two task handler bindings for Language SDK
authors
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (78995cf2159)
\
N -- N -- N
refs/heads/jason/core-taskhandler-refactor/06-go-sdk-task-handler-parse
(b1151dc3b23)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../lang-sdk/0011-mixed-language-dag-processing.md | 14 +++++----
.../adr/lang-sdk/0012-lang-sdk-parse-protocol.md | 20 +++++++------
.../0013-persisted-task-handler-bindings.md | 5 ++--
.../src/airflow/dag_processing/processor.py | 28 +++++++++++-------
.../tests/unit/dag_processing/test_processor.py | 34 ++++++++++++++--------
.../dag_processing/test_task_handler_processor.py | 4 +--
.../test_task_handler_processor_go.py | 18 ++++++++----
contributing-docs/30_new_language_sdk.rst | 28 +++++++++++-------
go-sdk/pkg/binding/declaration.go | 23 +++++----------
go-sdk/pkg/binding/declaration_test.go | 18 ++++++------
go-sdk/pkg/execution/genmodels/models.gen.go | 9 ++----
go-sdk/pkg/execution/integration_test.go | 5 +---
go-sdk/pkg/execution/task_handler_parse_test.go | 8 ++---
task-sdk/docs/lang-sdk-spec.rst | 7 +++--
.../airflow/sdk/execution_time/schema/schema.json | 28 +++++++++---------
ts-sdk/src/generated/supervisor.ts | 8 ++---
16 files changed, 138 insertions(+), 119 deletions(-)
