This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch jason/lang-sdk-e2e/08-native-e2e
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 0929f42b8eb Fix the native TypeScript example's trigger to the current
Dag.task API
discard 8ebb89cd6e6 Cover the same native Java Dag features in the k8s native
Dag test
discard 33a28955528 Cover If, Switch, a task group and TriggerDagRun in the
native Java Dag e2e
discard fc28f40daaf Exclude airflowignore_all from the license check
discard 433ceba2ef0 Rework the lang-SDK k8s harness for mixed-language and
native Dag tests
discard e19334afeed Keep the k8s lang-SDK values comment within the YAML line
limit
discard 29bc99c26dd Read a native Dag example's served Dags with bundleDags
discard d695b5501ac Say which coordinator runs the native e2e Java tasks
discard 9e2a16ccfb8 Drop the dag_bundle_name reason from the k8s native
TypeScript skip
discard 31f965ee89d Parse native Dags in the e2e by class, not by Dag bundle
name
discard b1cf1b5640c Name the skipped-branch e2e test after what it checks
discard e3174741a82 Document how the TypeScript example's native Dag gets
parsed
discard 42f206e1378 Explain why the k8s native TypeScript Dag test is skipped
discard fae6bcfcf2d Pack the TypeScript example against the built SDK
discard efbd941d246 Build the TypeScript SDK before packing the k8s example
bundle
discard 7d77655d43c Key the Lang-SDK e2e jobs on native Dag modules only
discard 89c61e5f0d2 Build the k8s TypeScript artifacts only for the native Dag
test
discard 459527076b5 Share the Dag run lookup and the native Java queue name
discard ac46031814a Run the Lang-SDK e2e jobs when native Dag parsing changes
discard 2dc2e367a8d Add a native Java Dag to the compose e2e
discard 1ea63e74408 Keep the containerized Java build's Maven repository on
the host
discard e96fe6f7a93 Check the native TypeScript Dag's source and triggered run
discard 2c850cbf41a Parse the native TypeScript Dag in the compose e2e
discard 734280ab0d4 TS SDK: cover native TypeScript Dags end to end
add e060e6c0b46 Document how bundles can discover the dag_id/task_id being
requested (#69697)
add 8533cc40b0a TS SDK: add the task state store to the task client
(#73618)
add 86ebf1c8a2d Add missing Taiwanese Mandarin translations for task
states and Dag list settings (#74486)
add 785d82da5c0 Cover native Go Dags in the go_sdk e2e test (#74411)
add dc38f84ff46 Consolidate in-process Execution API hosting (#73327)
add b8ef78f53ad Fix misleading timetable Variable example in best
practices (#73945)
add 1e404fac4ac Stop the scheduler crashing when a queued run's Dag fails
to deserialize (#74499)
add ea955744e4d Make airflow standalone discover new Dag files within
seconds (#74479)
add 0a913f21aa8 Use the configured API port in the default execution API
URL (#74478)
add 802f398731f Start a real login in the AWS auth manager system test
(#74431)
add aef881370ea Sync Dag permissions for CustomAuthManager (#74022)
add bdfc02b8ffb Fix GKE operator imports with older Kubernetes providers
(#74505)
add ad2ef0634ec Dedent task docstrings used as doc_md (#74436)
add 919765f3cf7 Rename the max_active_runs recompute test and drop a no-op
mock (#74483)
add 1f5331de1fa Document the experimental Dag importer interface (#74333)
add 8e14de67e3f Fix `KubernetesExecutor` leaving invalid-config tasks
stuck in queued (#74512)
add 07a0c4da099 Fix TypeError clearing a DAG run when a queued-at deadline
interval is stored as JSON (#70370)
add df7b8a7d4ca Bump the auth-ui-package-updates group across 1 directory
with 2 updates (#74507)
add 466e847d3de Add routable to docs spelling wordlist (#74526)
add bb721616ad0 Fix AWS auth manager login when the IdP is on another site
(#74529)
add 65a83820fef Let SandboxToolset be deep-copied again (#74525)
add 7675d8d2f39 Add missing UI translations for Greek(el) (#74460)
add 6255513a3b6 Add missing Polish UI translations (#74533)
add 9bf8cc0a6fb Add Snowflake Cortex Agent management operators (#70930)
add 0bae39f4884 Document that `SQLToolset` does not check functions
without `allowed_tables` (#74444)
add 1a6ea8899c3 UI: Group digits of counters in translated strings (#74296)
add 051d5d85d2f TS SDK: Add human-in-the-loop tasks to native Dags (#74484)
add e9efa470919 TS SDK: cover native TypeScript Dags end to end
add b86b3645b8a Parse the native TypeScript Dag in the compose e2e
add 86824c2e82d Check the native TypeScript Dag's source and triggered run
add 84897bb7a36 Keep the containerized Java build's Maven repository on
the host
add e5b7824d8a1 Add a native Java Dag to the compose e2e
add eced559d6be Run the Lang-SDK e2e jobs when native Dag parsing changes
add 0091f0032b5 Share the Dag run lookup and the native Java queue name
add 3c61f55f337 Build the k8s TypeScript artifacts only for the native Dag
test
add 842218142f7 Key the Lang-SDK e2e jobs on native Dag modules only
add 951477671bb Build the TypeScript SDK before packing the k8s example
bundle
add 253bfb84db8 Pack the TypeScript example against the built SDK
add f2a9f334ee4 Explain why the k8s native TypeScript Dag test is skipped
add 454c2e99b10 Document how the TypeScript example's native Dag gets
parsed
add 2ede3215d4f Name the skipped-branch e2e test after what it checks
add 923697e80f9 Parse native Dags in the e2e by class, not by Dag bundle
name
add 931ea735603 Drop the dag_bundle_name reason from the k8s native
TypeScript skip
add 2e1ce8974d3 Say which coordinator runs the native e2e Java tasks
add 9be77c222ec Read a native Dag example's served Dags with bundleDags
add 383ccfeeb70 Keep the k8s lang-SDK values comment within the YAML line
limit
add 18a9601e263 Rework the lang-SDK k8s harness for mixed-language and
native Dag tests
add d313c95251c Exclude airflowignore_all from the license check
add 31873463a49 Cover If, Switch, a task group and TriggerDagRun in the
native Java Dag e2e
add b91e38db846 Cover the same native Java Dag features in the k8s native
Dag test
add c3e39f1df3d Fix the native TypeScript example's trigger to the current
Dag.task API
add d610758ac59 Remove client methods a rebase onto main duplicated
add 5350cf9137f Fix the TS Code view test for per-Dag source
add 6f6e30c6577 Fix the Java trigger test's XCom key
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 (0929f42b8eb)
\
N -- N -- N refs/heads/jason/lang-sdk-e2e/08-native-e2e
(6f6e30c6577)
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:
.agents/skills/airflow-translations/SKILL.md | 4 +
.agents/skills/airflow-translations/locales/ar.md | 10 +-
.agents/skills/airflow-translations/locales/ca.md | 2 +-
.agents/skills/airflow-translations/locales/de.md | 2 +-
.agents/skills/airflow-translations/locales/el.md | 2 +-
.agents/skills/airflow-translations/locales/es.md | 2 +-
.agents/skills/airflow-translations/locales/fr.md | 2 +-
.agents/skills/airflow-translations/locales/he.md | 4 +-
.agents/skills/airflow-translations/locales/hu.md | 4 +-
.agents/skills/airflow-translations/locales/ja.md | 2 +-
.agents/skills/airflow-translations/locales/ko.md | 26 +-
.agents/skills/airflow-translations/locales/nl.md | 2 +-
.agents/skills/airflow-translations/locales/pl.md | 6 +-
.agents/skills/airflow-translations/locales/pt.md | 2 +-
.agents/skills/airflow-translations/locales/tr.md | 2 +-
.../skills/airflow-translations/locales/zh-CN.md | 12 +-
.../skills/airflow-translations/locales/zh-TW.md | 8 +-
.../administration-and-deployment/dag-bundles.rst | 24 +
.../dag-importers.rst | 169 ++++++
.../dagfile-processing.rst | 10 +-
.../docs/administration-and-deployment/index.rst | 1 +
.../administration-and-deployment/web-stack.rst | 13 +-
.../language-sdks/typescript.rst | 53 +-
airflow-core/docs/best-practices.rst | 52 +-
airflow-core/docs/core-concepts/dags.rst | 4 +-
airflow-core/docs/public-airflow-interface.rst | 16 +
airflow-core/newsfragments/74499.bugfix.rst | 1 +
airflow-core/src/airflow/api_fastapi/app.py | 3 +-
.../auth/managers/simple/ui/package.json | 4 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 176 +++----
.../src/airflow/api_fastapi/execution_api/app.py | 141 +----
.../api_fastapi/execution_api/in_process.py | 148 ++++++
.../src/airflow/cli/commands/standalone_command.py | 31 ++
.../src/airflow/config_templates/config.yml | 9 +-
.../src/airflow/dag_processing/collection.py | 18 +-
airflow-core/src/airflow/dag_processing/manager.py | 14 +-
.../src/airflow/dag_processing/processor.py | 8 -
.../src/airflow/executors/base_executor.py | 14 +-
.../src/airflow/jobs/scheduler_job_runner.py | 8 +-
.../src/airflow/jobs/triggerer_job_runner.py | 11 +-
airflow-core/src/airflow/models/taskinstance.py | 26 +-
airflow-core/src/airflow/serialization/decoders.py | 44 +-
.../src/airflow/serialization/definitions/dag.py | 26 +-
.../airflow/ui/public/i18n/locales/ar/admin.json | 12 +-
.../airflow/ui/public/i18n/locales/ar/common.json | 14 +-
.../ui/public/i18n/locales/ar/components.json | 56 +-
.../src/airflow/ui/public/i18n/locales/ar/dag.json | 30 +-
.../airflow/ui/public/i18n/locales/ar/dags.json | 4 +-
.../ui/public/i18n/locales/ar/dashboard.json | 18 +-
.../airflow/ui/public/i18n/locales/ar/hitl.json | 12 +-
.../airflow/ui/public/i18n/locales/ca/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/ca/browse.json | 2 +-
.../airflow/ui/public/i18n/locales/ca/common.json | 16 +-
.../ui/public/i18n/locales/ca/components.json | 40 +-
.../src/airflow/ui/public/i18n/locales/ca/dag.json | 24 +-
.../airflow/ui/public/i18n/locales/ca/dags.json | 4 +-
.../ui/public/i18n/locales/ca/dashboard.json | 14 +-
.../airflow/ui/public/i18n/locales/ca/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/de/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/de/browse.json | 4 +-
.../airflow/ui/public/i18n/locales/de/common.json | 16 +-
.../ui/public/i18n/locales/de/components.json | 40 +-
.../src/airflow/ui/public/i18n/locales/de/dag.json | 24 +-
.../airflow/ui/public/i18n/locales/de/dags.json | 4 +-
.../ui/public/i18n/locales/de/dashboard.json | 12 +-
.../airflow/ui/public/i18n/locales/de/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/el/admin.json | 19 +-
.../airflow/ui/public/i18n/locales/el/assets.json | 16 +-
.../airflow/ui/public/i18n/locales/el/browse.json | 32 ++
.../airflow/ui/public/i18n/locales/el/common.json | 143 ++++-
.../ui/public/i18n/locales/el/components.json | 70 ++-
.../src/airflow/ui/public/i18n/locales/el/dag.json | 101 +++-
.../airflow/ui/public/i18n/locales/el/dags.json | 49 +-
.../ui/public/i18n/locales/el/dashboard.json | 27 +-
.../airflow/ui/public/i18n/locales/el/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/en/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/en/browse.json | 2 +-
.../airflow/ui/public/i18n/locales/en/common.json | 16 +-
.../ui/public/i18n/locales/en/components.json | 30 +-
.../src/airflow/ui/public/i18n/locales/en/dag.json | 24 +-
.../airflow/ui/public/i18n/locales/en/dags.json | 4 +-
.../ui/public/i18n/locales/en/dashboard.json | 14 +-
.../airflow/ui/public/i18n/locales/en/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/es/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/es/common.json | 16 +-
.../ui/public/i18n/locales/es/components.json | 28 +-
.../src/airflow/ui/public/i18n/locales/es/dag.json | 20 +-
.../airflow/ui/public/i18n/locales/es/dags.json | 4 +-
.../ui/public/i18n/locales/es/dashboard.json | 10 +-
.../airflow/ui/public/i18n/locales/es/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/fr/admin.json | 8 +-
.../airflow/ui/public/i18n/locales/fr/browse.json | 6 +-
.../airflow/ui/public/i18n/locales/fr/common.json | 20 +-
.../ui/public/i18n/locales/fr/components.json | 60 +--
.../src/airflow/ui/public/i18n/locales/fr/dag.json | 34 +-
.../airflow/ui/public/i18n/locales/fr/dags.json | 4 +-
.../ui/public/i18n/locales/fr/dashboard.json | 20 +-
.../airflow/ui/public/i18n/locales/fr/hitl.json | 10 +-
.../airflow/ui/public/i18n/locales/he/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/he/common.json | 14 +-
.../ui/public/i18n/locales/he/components.json | 22 +-
.../src/airflow/ui/public/i18n/locales/he/dag.json | 22 +-
.../airflow/ui/public/i18n/locales/he/dags.json | 4 +-
.../ui/public/i18n/locales/he/dashboard.json | 10 +-
.../airflow/ui/public/i18n/locales/he/hitl.json | 10 +-
.../airflow/ui/public/i18n/locales/hi/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/hi/common.json | 12 +-
.../ui/public/i18n/locales/hi/components.json | 26 +-
.../src/airflow/ui/public/i18n/locales/hi/dag.json | 20 +-
.../airflow/ui/public/i18n/locales/hi/dags.json | 4 +-
.../ui/public/i18n/locales/hi/dashboard.json | 10 +-
.../airflow/ui/public/i18n/locales/hi/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/hu/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/hu/common.json | 12 +-
.../ui/public/i18n/locales/hu/components.json | 28 +-
.../src/airflow/ui/public/i18n/locales/hu/dag.json | 20 +-
.../airflow/ui/public/i18n/locales/hu/dags.json | 4 +-
.../ui/public/i18n/locales/hu/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/hu/hitl.json | 4 +-
.../airflow/ui/public/i18n/locales/it/admin.json | 8 +-
.../airflow/ui/public/i18n/locales/it/common.json | 4 +-
.../ui/public/i18n/locales/it/components.json | 44 +-
.../src/airflow/ui/public/i18n/locales/it/dag.json | 6 +-
.../airflow/ui/public/i18n/locales/it/dags.json | 4 +-
.../ui/public/i18n/locales/it/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/it/hitl.json | 6 +-
.../airflow/ui/public/i18n/locales/ja/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/ja/common.json | 4 +-
.../ui/public/i18n/locales/ja/components.json | 24 +-
.../src/airflow/ui/public/i18n/locales/ja/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/ja/dags.json | 4 +-
.../ui/public/i18n/locales/ja/dashboard.json | 4 +-
.../airflow/ui/public/i18n/locales/ja/hitl.json | 4 +-
.../airflow/ui/public/i18n/locales/ko/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/ko/browse.json | 2 +-
.../airflow/ui/public/i18n/locales/ko/common.json | 16 +-
.../ui/public/i18n/locales/ko/components.json | 28 +-
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 20 +-
.../airflow/ui/public/i18n/locales/ko/dags.json | 4 +-
.../ui/public/i18n/locales/ko/dashboard.json | 14 +-
.../airflow/ui/public/i18n/locales/ko/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/nl/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/nl/common.json | 12 +-
.../ui/public/i18n/locales/nl/components.json | 26 +-
.../src/airflow/ui/public/i18n/locales/nl/dag.json | 20 +-
.../airflow/ui/public/i18n/locales/nl/dags.json | 4 +-
.../ui/public/i18n/locales/nl/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/nl/hitl.json | 8 +-
.../airflow/ui/public/i18n/locales/pl/admin.json | 13 +-
.../airflow/ui/public/i18n/locales/pl/assets.json | 1 +
.../airflow/ui/public/i18n/locales/pl/browse.json | 6 +-
.../airflow/ui/public/i18n/locales/pl/common.json | 68 ++-
.../ui/public/i18n/locales/pl/components.json | 91 ++--
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 108 +++-
.../airflow/ui/public/i18n/locales/pl/dags.json | 25 +-
.../ui/public/i18n/locales/pl/dashboard.json | 35 +-
.../airflow/ui/public/i18n/locales/pl/hitl.json | 12 +-
.../airflow/ui/public/i18n/locales/pt/admin.json | 8 +-
.../airflow/ui/public/i18n/locales/pt/common.json | 10 +-
.../ui/public/i18n/locales/pt/components.json | 44 +-
.../src/airflow/ui/public/i18n/locales/pt/dag.json | 6 +-
.../airflow/ui/public/i18n/locales/pt/dags.json | 4 +-
.../ui/public/i18n/locales/pt/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/pt/hitl.json | 6 +-
.../airflow/ui/public/i18n/locales/ru/admin.json | 12 +-
.../airflow/ui/public/i18n/locales/ru/common.json | 16 +-
.../ui/public/i18n/locales/ru/components.json | 58 +-
.../src/airflow/ui/public/i18n/locales/ru/dag.json | 36 +-
.../airflow/ui/public/i18n/locales/ru/dags.json | 4 +-
.../ui/public/i18n/locales/ru/dashboard.json | 18 +-
.../airflow/ui/public/i18n/locales/ru/hitl.json | 12 +-
.../airflow/ui/public/i18n/locales/th/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/th/common.json | 4 +-
.../ui/public/i18n/locales/th/components.json | 16 +-
.../src/airflow/ui/public/i18n/locales/th/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/th/dags.json | 4 +-
.../ui/public/i18n/locales/th/dashboard.json | 4 +-
.../airflow/ui/public/i18n/locales/th/hitl.json | 4 +-
.../airflow/ui/public/i18n/locales/tr/admin.json | 4 +-
.../airflow/ui/public/i18n/locales/tr/common.json | 12 +-
.../ui/public/i18n/locales/tr/components.json | 26 +-
.../src/airflow/ui/public/i18n/locales/tr/dag.json | 20 +-
.../airflow/ui/public/i18n/locales/tr/dags.json | 4 +-
.../ui/public/i18n/locales/tr/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/tr/hitl.json | 4 +-
.../ui/public/i18n/locales/zh-CN/admin.json | 4 +-
.../ui/public/i18n/locales/zh-CN/common.json | 12 +-
.../ui/public/i18n/locales/zh-CN/components.json | 26 +-
.../airflow/ui/public/i18n/locales/zh-CN/dag.json | 14 +-
.../airflow/ui/public/i18n/locales/zh-CN/dags.json | 4 +-
.../ui/public/i18n/locales/zh-CN/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/zh-CN/hitl.json | 8 +-
.../ui/public/i18n/locales/zh-TW/admin.json | 4 +-
.../ui/public/i18n/locales/zh-TW/browse.json | 2 +-
.../ui/public/i18n/locales/zh-TW/common.json | 23 +-
.../ui/public/i18n/locales/zh-TW/components.json | 30 +-
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 22 +-
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 11 +-
.../ui/public/i18n/locales/zh-TW/dashboard.json | 12 +-
.../airflow/ui/public/i18n/locales/zh-TW/hitl.json | 8 +-
airflow-core/src/airflow/ui/src/i18n/config.ts | 10 +
.../src/airflow/ui/src/i18n/locales.test.ts | 101 ++++
.../ui/src/pages/Dag/Versions/VersionDiff.test.tsx | 4 +-
.../tests/unit/always/test_project_structure.py | 2 +
.../unit/api_fastapi/execution_api/test_app.py | 45 ++
.../api_fastapi/execution_api/test_in_process.py | 60 +++
airflow-core/tests/unit/api_fastapi/test_app.py | 2 +-
.../unit/cli/commands/test_standalone_command.py | 51 ++
.../tests/unit/dag_processing/test_collection.py | 64 ++-
.../tests/unit/dag_processing/test_processor.py | 2 +-
.../tests/unit/executors/test_local_executor.py | 32 ++
airflow-core/tests/unit/jobs/test_scheduler_job.py | 66 ++-
airflow-core/tests/unit/models/test_dagrun.py | 18 +
.../tests/unit/models/test_taskinstance.py | 156 +++++-
.../tests/unit/serialization/test_decoders.py | 84 +++
airflow-e2e-tests/docker/go.yml | 7 +
airflow-e2e-tests/docker/ts.yml | 10 +-
.../tests/airflow_e2e_tests/conftest.py | 52 +-
.../tests/airflow_e2e_tests/constants.py | 3 +
.../airflow_e2e_tests/e2e_test_utils/clients.py | 37 +-
.../go_sdk_tests/test_go_sdk_native_dag.py | 220 ++++++++
.../java_sdk_tests/test_java_sdk_native_dag.py | 2 +-
.../ts_sdk_tests/test_ts_sdk_dag.py | 65 ++-
.../ts_sdk_tests/test_ts_sdk_hitl.py | 200 +++++++
.../ts_sdk_tests/test_ts_sdk_native_dag.py | 6 +-
.../src/airflow_breeze/commands/ui_commands.py | 8 +-
dev/breeze/tests/test_ui_commands.py | 9 +
docs/spelling_wordlist.txt | 1 +
go-sdk/example/native/main.go | 177 +++++++
.../factory.go => example/native/report.go} | 20 +-
.../docs/auth-manager/setup/identity-center.rst | 10 +
.../amazon/aws/auth_manager/routes/login.py | 9 +-
.../amazon/aws/tests/test_aws_auth_manager.py | 65 ++-
.../amazon/aws/auth_manager/routes/test_login.py | 27 +-
.../kubernetes/executors/kubernetes_executor.py | 3 +-
.../executors/test_kubernetes_executor.py | 40 ++
providers/common/ai/docs/agent_security.rst | 12 +-
providers/common/ai/docs/toolsets/sql.rst | 16 +
.../providers/common/ai/toolsets/sandbox.py | 16 +-
.../tests/unit/common/ai/toolsets/test_sandbox.py | 24 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 9 +
.../unit/fab/auth_manager/test_fab_auth_manager.py | 18 +
.../google/cloud/operators/kubernetes_engine.py | 26 +-
.../cloud/operators/test_kubernetes_engine.py | 39 +-
.../docs/operators/snowflake_cortex_agent.rst | 108 ++--
.../snowflake/operators/snowflake_cortex_agent.py | 278 +++++++++-
.../snowflake/example_snowflake_cortex_agent.py | 60 ++-
.../operators/test_snowflake_cortex_agent.py | 309 +++++++++--
scripts/ci/prek/generate_execution_api_schema.py | 2 +
task-sdk/docs/api.rst | 35 ++
task-sdk/src/airflow/sdk/bases/decorator.py | 4 +-
task-sdk/tests/task_sdk/bases/test_decorator.py | 12 +
.../task_sdk/execution_time/test_task_runner.py | 75 ++-
ts-sdk/README.md | 109 +++-
ts-sdk/api-docs/dag-authoring-api.ts | 12 +-
.../rules/levels.js => ts-sdk/api-docs/hitl-api.ts | 19 +-
ts-sdk/api-docs/supporting-types.ts | 8 +-
ts-sdk/capabilities.yaml | 14 +-
ts-sdk/example/dags/typescript_example.py | 10 +
ts-sdk/example/package.json | 4 +-
ts-sdk/example/src/ai-approval.ts | 198 +++++++
ts-sdk/example/src/hitl.ts | 137 +++++
ts-sdk/example/src/main.ts | 36 +-
ts-sdk/package.json | 4 +
ts-sdk/src/coordinator/client.ts | 217 +++++++-
ts-sdk/src/coordinator/operator-runner.ts | 140 +++++
ts-sdk/src/coordinator/protocol.ts | 9 +
ts-sdk/src/coordinator/runtime.ts | 65 ++-
ts-sdk/src/coordinator/serde.ts | 275 +---------
.../DataTable => ts-sdk/src/hitl}/index.ts | 12 +-
ts-sdk/src/hitl/operator.ts | 281 ++++++++++
ts-sdk/src/hitl/spec.ts | 447 ++++++++++++++++
ts-sdk/src/index.ts | 11 +-
ts-sdk/src/sdk/bundle.ts | 30 +-
ts-sdk/src/sdk/client-types.ts | 23 +
ts-sdk/src/sdk/client.ts | 74 ++-
ts-sdk/src/sdk/dag-graph.ts | 236 +++++++++
ts-sdk/src/sdk/dag.ts | 117 +++--
.../Grid/gridHover.css => ts-sdk/src/sdk/env.ts | 16 +-
ts-sdk/src/sdk/operator.ts | 150 ++++++
ts-sdk/src/sdk/plain-json.ts | 60 +++
.../trigger-dag-run-execute.ts} | 106 +---
ts-sdk/src/sdk/trigger-dag-run.ts | 43 +-
ts-sdk/tests/coordinator/client.test.ts | 238 ++++++++-
ts-sdk/tests/coordinator/integration.test.ts | 584 ++++++++++++++++++++-
ts-sdk/tests/coordinator/operator-runner.test.ts | 207 ++++++++
ts-sdk/tests/hitl/operator.test.ts | 169 ++++++
ts-sdk/tests/hitl/spec.test.ts | 353 +++++++++++++
ts-sdk/tests/public-api.test.ts | 28 +
ts-sdk/tests/sdk/dag.test.ts | 35 ++
ts-sdk/tests/sdk/hitl-inference.test.ts | 117 +++++
ts-sdk/tests/sdk/trigger-dag-run.test.ts | 21 +-
292 files changed, 8930 insertions(+), 2152 deletions(-)
create mode 100644
airflow-core/docs/administration-and-deployment/dag-importers.rst
create mode 100644 airflow-core/newsfragments/74499.bugfix.rst
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/in_process.py
create mode 100644 airflow-core/src/airflow/ui/src/i18n/locales.test.ts
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/test_in_process.py
create mode 100644 airflow-core/tests/unit/serialization/test_decoders.py
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_hitl.py
create mode 100644 go-sdk/example/native/main.go
copy go-sdk/{cmd/airflow-go-pack/testdata/multidag/factory/factory.go =>
example/native/report.go} (69%)
copy
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/rules/levels.js =>
ts-sdk/api-docs/hitl-api.ts (78%)
create mode 100644 ts-sdk/example/src/ai-approval.ts
create mode 100644 ts-sdk/example/src/hitl.ts
create mode 100644 ts-sdk/src/coordinator/operator-runner.ts
copy {airflow-core/src/airflow/ui/src/components/DataTable =>
ts-sdk/src/hitl}/index.ts (81%)
create mode 100644 ts-sdk/src/hitl/operator.ts
create mode 100644 ts-sdk/src/hitl/spec.ts
create mode 100644 ts-sdk/src/sdk/dag-graph.ts
copy airflow-core/src/airflow/ui/src/layouts/Details/Grid/gridHover.css =>
ts-sdk/src/sdk/env.ts (60%)
create mode 100644 ts-sdk/src/sdk/operator.ts
create mode 100644 ts-sdk/src/sdk/plain-json.ts
rename ts-sdk/src/{coordinator/trigger-runner.ts =>
sdk/trigger-dag-run-execute.ts} (67%)
create mode 100644 ts-sdk/tests/coordinator/operator-runner.test.ts
create mode 100644 ts-sdk/tests/hitl/operator.test.ts
create mode 100644 ts-sdk/tests/hitl/spec.test.ts
create mode 100644 ts-sdk/tests/sdk/hitl-inference.test.ts
