This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch
jason/core-taskhandler-refactor/05-runtime-parse-transport
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 11b1aa6a6ce Close the fake runtime's sockets when its reply is done
discard 2e1afe349eb Name the runtime transport test helpers with verbs
discard 86a2133932f Patch with decorators in the runtime transport tests
discard 62e2855bd7c Hang the fake runtimes without sleeping
discard 8c695ad30c0 Test that a start failing before the fork closes its
listeners
discard 31eaa27e543 Spec the mocks in the runtime transport and probe tests
discard 431975d5092 Import ctypes at the top of the subprocess coordinator
module
discard 829768b7f98 Pass the binding mode in the task-handler probe tests
discard 48ec2d68960 Tidy the runtime transport and the coordinator lookup
discard d222f346180 Clean up a Lang-SDK runtime parse whose start fails after
the fork
discard 68f8b6a9661 Do not exec a Lang-SDK runtime whose parent has already
exited
discard 574fdc0598b Kill what a Lang-SDK runtime leaves behind when it exits
discard e32271e6350 Read a Lang-SDK runtime's frames without blocking the
parse loop
discard d5781c3bfe6 Probe a Lang-SDK artifact for its task handlers
discard 8554e8f1ca5 Keep a nested supervised child's standard streams open
discard ad24f837beb Make the Dag file processor base generic over its result
discard b0c07d0bf37 Let a subprocess coordinator exec a task-handler parse
runtime
discard 6b23ddc4205 Add the named_open binding to the Lang-SDK ADRs
discard dc331d7eb3b Regenerate TS SDK supervisor types for the named_open
binding
discard d4d103f9217 Add a named_open binding for non-exhaustive task-handler
params
discard 1360aa4af35 Describe the binding-mode parse check in ADR-0011 and
ADR-0013
discard 847e4b5b456 Describe the task-handler binding mode in ADR-0012
discard 088360ba388 Regenerate TS SDK supervisor types for the binding mode
discard d4bdedae978 Add a binding mode to task-handler declarations
discard 6fd00cdd521 Document the version rules for a new supervisor schema body
discard 95285b73fb3 Regenerate TS SDK supervisor types for task-handler
messages
discard 0cb7a22b023 Add task-handler parse messages and their parse-channel
union
discard 72f869f68c7 Test closing a Dag file processor that has no parse log
file
discard 52a6e52b0aa Move the Dag file processor's shared plumbing into a base
class
add 190ebe44ac9 Cache an artifact's task handlers on its row, not on each
binding
add a25eb7bbae6 Move the handler declarations to the artifact in
ADR-0013's SQL
add ad99d4bb954 Let a task handler artifact store no cache digest
add 0cafad2a563 Allow a NULL cache digest in ADR-0013's artifact table SQL
add d301fee5d6c Move the Dag file processor's shared plumbing into a base
class
add e9b1ba3f249 Test closing a Dag file processor that has no parse log
file
add afcd4e6eb31 Add task-handler parse messages and their parse-channel
union
add 4e462352188 Regenerate TS SDK supervisor types for task-handler
messages
add c08b607a132 Document the version rules for a new supervisor schema body
add ffbd6892edb Add a binding mode to task-handler declarations
add b6137fe719e Regenerate TS SDK supervisor types for the binding mode
add e37df9a8e18 Describe the task-handler binding mode in ADR-0012
add 5b2d32caa7a Describe the binding-mode parse check in ADR-0011 and
ADR-0013
add 48c7217ec34 Add a named_open binding for non-exhaustive task-handler
params
add 267cc098be0 Regenerate TS SDK supervisor types for the named_open
binding
add b1b645435cd Add the named_open binding to the Lang-SDK ADRs
add 84460f71c1f Ask a task handler runtime for every handler it registers
add 68e0cdddd0d Regenerate TS SDK supervisor types for the probe without
dag_ids
add 020bdcc03ca Describe the all-handlers probe in ADR-0011 and ADR-0012
add 0e65496cbc6 Let a subprocess coordinator exec a task-handler parse
runtime
add b98c1882b65 Make the Dag file processor base generic over its result
add 6da772bd023 Keep a nested supervised child's standard streams open
add 6a77bfb1bd9 Probe a Lang-SDK artifact for its task handlers
add b4b98407ce5 Read a Lang-SDK runtime's frames without blocking the
parse loop
add 8c7e2888e59 Kill what a Lang-SDK runtime leaves behind when it exits
add de45ceba937 Do not exec a Lang-SDK runtime whose parent has already
exited
add d43b88f1a1a Clean up a Lang-SDK runtime parse whose start fails after
the fork
add 45580954214 Tidy the runtime transport and the coordinator lookup
add 8323e15e104 Pass the binding mode in the task-handler probe tests
add 173ac921a5d Import ctypes at the top of the subprocess coordinator
module
add cb8e7b92e57 Spec the mocks in the runtime transport and probe tests
add 86b6a606d85 Test that a start failing before the fork closes its
listeners
add 274b750192c Hang the fake runtimes without sleeping
add e04b994ae7c Patch with decorators in the runtime transport tests
add acba2e5ca6a Name the runtime transport test helpers with verbs
add 12301131f0a Close the fake runtime's sockets when its reply is done
add 0b77a65e354 Probe a task handler artifact without naming Dags
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 (11b1aa6a6ce)
\
N -- N -- N
refs/heads/jason/core-taskhandler-refactor/05-runtime-parse-transport
(0b77a65e354)
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 | 20 +++----
.../adr/lang-sdk/0012-lang-sdk-parse-protocol.md | 12 ++---
.../0013-persisted-task-handler-bindings.md | 14 +++--
.../src/airflow/dag_processing/processor.py | 10 ++--
.../dag_processing/task_handler_processor.py | 10 ++--
.../0141_3_4_0_add_lang_sdk_task_handler_tables.py | 5 +-
.../src/airflow/models/lang_sdk_task_handler.py | 15 ++++--
.../unit/dag_processing/test_lang_sdk_runtime.py | 10 ++--
.../dag_processing/test_task_handler_processor.py | 10 ++--
.../unit/models/test_lang_sdk_task_handler.py | 63 +++++++++++++++-------
.../airflow/sdk/execution_time/schema/schema.json | 12 +----
ts-sdk/src/generated/supervisor.ts | 8 +--
12 files changed, 99 insertions(+), 90 deletions(-)
