Parse native Lang-SDK Dags in the Dag processor with their runtime by jason810496 · Pull Request #74035 · apache/airflow

Parse coordinator-claimed Dag files with their runtime in the Dag processor

jason810496

committed

f1070b3

Report a Lang-SDK parse past its import timeout as an import error

jason810496

committed

c8a3306

Report a native Dag's task that reaches a Python worker

jason810496

committed

bbea648

Drop callbacks for Lang-SDK Dag files before queuing the file

jason810496

committed

18de8bf

Start each Dag file processor with explicit arguments

jason810496

committed

a635923

Find the claiming coordinator in the Task SDK and wrap it in core

jason810496

committed

17f65af

Fail a native Dag's task on a Python worker without retries

jason810496

committed

2d6dd21

Match the schema error's JSON path in a Lang-SDK parse test

jason810496

committed

1169dbb

Kill what a Lang-SDK runtime leaves in its process group

jason810496

committed

303b0be

Name the setting in a Lang-SDK parse timeout error

jason810496

committed

19810c7

Spec the mocks of a hand-built Lang-SDK processor in tests

jason810496

committed

b5ed506

Apply the multi-team task checks to Lang-SDK Dags

jason810496

committed

58c6665

Clear import errors after the native-file Dag bag sync test

jason810496

committed

913e536

Note in ADR-0010 that the manager routes claimed files for now

jason810496

committed

22cd5aa

Move the client-less Lang-SDK parse out of this change

jason810496

committed

e434a39

Wait for the killed leftover in the Lang-SDK processor test

jason810496

committed

0e680a3

Find a native Dag's coordinator key through its importer

jason810496

committed

eb25849

Pass a parse log handle to the Lang-SDK processor in tests

jason810496

committed

4ad0614

Stub Dag file discovery with DagFileInfo in the Lang-SDK manager tests

jason810496

committed

435e639

Name the coordinator class a native Dag task must be routed to

jason810496

committed

e62a481

Find a claiming Dag importer instead of its coordinator in Dag processing

jason810496

committed

18744e8

Test the import errors of a bundle with several coordinators of a class

jason810496

committed

302b4e0

Apply the team rules to the Dag that validation returns

jason810496

committed

9007b91

Catch a runtime's dead connection when its parse request is sent

jason810496

and

claude

committed

cb9d1e9

Navigation Menu

Repository navigation

Parse native Lang-SDK Dags in the Dag processor with their runtime - #74035

Parse native Lang-SDK Dags in the Dag processor with their runtime#74035
jason810496 merged 24 commits into
mainfrom
jason/lang-sdk-e2e/03-native-dag-parse

Commits on Oct 5, 2026

Parse coordinator-claimed Dag files with their runtime in the Dag processor

Report a Lang-SDK parse past its import timeout as an import error

Report a native Dag's task that reaches a Python worker

Drop callbacks for Lang-SDK Dag files before queuing the file

Start each Dag file processor with explicit arguments

Find the claiming coordinator in the Task SDK and wrap it in core

Fail a native Dag's task on a Python worker without retries

Match the schema error's JSON path in a Lang-SDK parse test

Kill what a Lang-SDK runtime leaves in its process group

Name the setting in a Lang-SDK parse timeout error

Spec the mocks of a hand-built Lang-SDK processor in tests

Apply the multi-team task checks to Lang-SDK Dags

Clear import errors after the native-file Dag bag sync test

Note in ADR-0010 that the manager routes claimed files for now

Move the client-less Lang-SDK parse out of this change

Wait for the killed leftover in the Lang-SDK processor test

Find a native Dag's coordinator key through its importer

Pass a parse log handle to the Lang-SDK processor in tests

Stub Dag file discovery with DagFileInfo in the Lang-SDK manager tests

Name the coordinator class a native Dag task must be routed to

Find a claiming Dag importer instead of its coordinator in Dag processing

Test the import errors of a bundle with several coordinators of a class

Apply the team rules to the Dag that validation returns

Catch a runtime's dead connection when its parse request is sent