Repository navigation

[DON'T MERGE] Java SDK All - #65960

Closed

jason810496 wants to merge 80 commits into

apache:mainfrom

astronomer:feature/java-all

Closed

[DON'T MERGE] Java SDK All#65960
jason810496 wants to merge 80 commits into
apache:mainfrom
astronomer:feature/java-all

Commits on May 6, 2026
- Add Task Coordinators and Dag File Processor
  jason810496
  committed
  dfa07b0
- Add initial Java provider for Apache Airflow
  jason810496
  committed
  dd2e24d
- Add common selector loop utilities for socket I/O handling for subprocesses
  jason810496
  committed
  9a771f5
- Implement Java DAG file processor with TCP communication bridge
  jason810496
  committed
  a8386fc
- Make JavaDagFileProcessor.can_handle aware of jar file content
  jason810496
  committed
  4c2ee0e
- Fix java process startup issue
  jason810496
  committed
  933171c
- Fix sockets bidning
  jason810496
  committed
  5c51d0d
- Refactor Java DAG file processor to use selector-based I/O multiplexing for improved performance and reliability
  jason810496
  committed
  18a70d7
- Add BaseLocaleCoordinator for non-Python DAG file processing and task execution
  jason810496
  committed
  78eb3ec
- Implement JavaLocaleCoordinator
  jason810496
  committed
  2895195
- Add Java task coordinator and entrypoint for locale-specific execution
  jason810496
  committed
  d4f5ce3
- Refactor Java provider to with generic process coordinators and update related components
  jason810496
  committed
  e31ec60
- Fix Coordinator by getting the correct dag bundle and dag path
  jason810496
  committed
  7c8f352
- Make @task.stub(language=java) works
  jason810496
  committed
  5df4fe0
- Make coordinator respect Jar bundle based on TI workload type
  jason810496
  committed
  340ef89
- Add java_sdk_setup script for Breeze
  jason810496
  committed
  e59df36
- Add get_code_from_file interface for BaseLocaleCoordinator
  jason810496
  committed
  03631ed
- Fix the 'Pure Java Dag' disappear in metadata DB issue
  jason810496
  committed
  fc17fae
- Refactor process coordinators to runtime coordinators
  jason810496
  committed
  1978b92
- Rename stub operator language field as sdk
  jason810496
  committed
  ba4ba6c
- Rename languages.java provider to sdk.java
  jason810496
  committed
  6eb4784
- Add unit tests for socket handling and selector loop functionality
  jason810496
  committed
  c898258
- Move TaskInstanceDTO to share to make task_runner retrieve TI.queue
  jason810496
  committed
  59496a3
- Add [workers/queue_to_runtime_mapping]
  jason810496
  committed
  fc642fb
- Remove the sdk field from stub operator and respect [workers/queue_to_runtime_mapping] config
  jason810496
  committed
  26764dd
- Rename `[workers] queue_to_runtime_mapping` to `[sdk] queue_to_sdk`
  jason810496
  committed
  7625345
- Simplify coordinator-related names (#1569)
  
  uranusjr
  authored and
  jason810496
  committed
  5ba3967
- CI: Add mypy and unit tests for shared/workloads
  jason810496
  committed
  ea4eef9
- CI: Fix DB migration and breeze images
  jason810496
  committed
  5c803dd
- CI: Fix failing items
  jason810496
  committed
  1c97cf3
- CI: Fix failing items
  jason810496
  committed
  9c7b41c
- CI: Add compat for create_runtime_ti pytest fixture
  jason810496
  committed
  81d720b
- CI: Fix Java provider test to include configuration options
  jason810496
  committed
  f8388c9
- CI: Fix self-review nits
  jason810496
  committed
  6467fb1
- Revert MappedOperator change
  jason810496
  committed
  375eaa9
- CI: Fix failing items
  jason810496
  committed
  e615c97
- CI: Fix Task SDK test_task_runner failures using TaskInstanceDTO
  jason810496
  committed
  36d0bdf
- CI: Skip non-JAR paths in JavaCoordinator.can_handle_dag_file
  jason810496
  committed
  4c58701
- CI: Drop literal Example: line from queue_to_sdk config description
  jason810496
  committed
  c938a38
- CI: Skip sdk-java provider in compat tests for older Airflow
  jason810496
  committed
  abfade1
- CI: Fix MyPy Liskov violation in JavaCoordinator.task_execution_cmd
  jason810496
  committed
  52ce0ff
- CI: Fix sdk-java docs build warnings
  jason810496
  committed
  e915473
- CI: Update SDK Java configuration and documentation references
  jason810496
  committed
  316c29a
- CI: Update map_index handling and add fixture to restore process context in tests
  jason810496
  committed
  8281739
- CI: Refactor map_index handling and update time travel decorators for timezone awareness in tests
  jason810496
  committed
  58a6001
- CI: Replace TaskInstance with TaskInstanceDTO and add additional parameters in test_supervisor
  jason810496
  committed
  d9c2b4a
- CI: Update test cases to use -1 for map_index and add additional parameters in TestCommsDecoder
  jason810496
  committed
  66eece7
- Remove shared workloads dependency and refactor TaskInstanceDTO usage
  jason810496
  committed
  837d964
- Move sdk.java out of provider as apache-airflow-coordinators-java distribution
  jason810496
  committed
  b1125a1
- Add Task Coordinators and Dag File Processor
  jason810496
  committed
  044f3ee
- Add initial Java provider for Apache Airflow
  jason810496
  committed
  0c6e0ba
- Implement Java DAG file processor with TCP communication bridge
  jason810496
  committed
  4b45c31
- Make JavaDagFileProcessor.can_handle aware of jar file content
  jason810496
  committed
  9b876b2
- Fix java process startup issue
  jason810496
  committed
  ac239b1
- Fix sockets bidning
  jason810496
  committed
  585e336
- Refactor Java DAG file processor to use selector-based I/O multiplexing for improved performance and reliability
  jason810496
  committed
  d0cd683
- Implement JavaLocaleCoordinator
  jason810496
  committed
  5645afc
- Add Java task coordinator and entrypoint for locale-specific execution
  jason810496
  committed
  5dc37ef
- Refactor Java provider to with generic process coordinators and update related components
  jason810496
  committed
  64416c4
- Fix Coordinator by getting the correct dag bundle and dag path
  jason810496
  committed
  c2c8fd9
- Make @task.stub(language=java) works
  jason810496
  committed
  2cf2b85
- Make coordinator respect Jar bundle based on TI workload type
  jason810496
  committed
  bc30f01
- Add get_code_from_file interface for BaseLocaleCoordinator
  jason810496
  committed
  d542bca
- Fix the 'Pure Java Dag' disappear in metadata DB issue
  jason810496
  committed
  ac21b39
- Refactor process coordinators to runtime coordinators
  jason810496
  committed
  0891041
- Initial Java-SDK
  jason810496
  committed
  8462e1c
- Add Java SDK e2e tests
  jason810496
  committed
  30aae4d
- Add check-java-serialization-compatibility prek hook
  jason810496
  committed
  07d1e50
- Breeze start-airflow setup with Java SDK
  jason810496
  committed
  32b135b
- Rename stub operator language field as sdk
  jason810496
  committed
  e01698c
- Cache gradle deps for breeze start-airflow
  jason810496
  committed
  fb815c3
- Rename languages.java provider to sdk.java
  jason810496
  committed
  4688d77
- Move TaskInstanceDTO to share to make task_runner retrieve TI.queue
  jason810496
  committed
  19348e3
- Add [workers/queue_to_runtime_mapping]
  jason810496
  committed
  04fa3cf
- Remove the sdk field from stub operator and respect [workers/queue_to_runtime_mapping] config
  jason810496
  committed
  bc6eb17
- Rename `[workers] queue_to_runtime_mapping` to `[sdk] queue_to_sdk`
  jason810496
  committed
  dbfa343
- Simplify coordinator-related names (#1569)
  
  uranusjr
  authored and
  jason810496
  committed
  1f6644f
- Add ADRs for JavaSDK and Coordinator
  jason810496
  committed
  21dbbda
Commits on May 7, 2026
- Update new coordinator config setup in java_sdk_build.sh
  jason810496
  committed
  4d4bb81
- Update JavaSDK e2e setup with the latest coordinator config
  jason810496
  committed
  0225b6f

Commits

Commits on May 6, 2026

Commits on May 7, 2026