This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a change to branch backport-edcd4a5-v3-4-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 560655fcfaa [v3-4-test] Hide assets the caller may not read from the
UI dependencies graph (#73008)
add 02c43a1dd58 [v3-4-test] Fix duplicate pending Dag runs for the same
asset partition key (#71074) (#75382)
add 9cd18837534 [v3-4-test] Make Java SDK context signal-aware (#74690)
(#75386)
add 2d0c99800e8 Merge branch 'v3-4-test' into backport-edcd4a5-v3-4-test
No new revisions were added by this update.
Summary of changes:
.../language-sdks/java.rst | 47 ++++
airflow-core/docs/migrations-ref.rst | 5 +-
airflow-core/src/airflow/assets/manager.py | 281 ++++++++++----------
...0148_3_4_0_add_pending_partition_key_to_apdr.py | 84 ++++++
airflow-core/src/airflow/models/asset.py | 33 ++-
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/tests/unit/assets/test_manager.py | 283 ++++++++++++++++++--
.../test_0148_add_pending_partition_key_to_apdr.py | 187 +++++++++++++
.../org/apache/airflow/e2e/TestBundleBuilder.java | 33 ++-
.../src/resources/dags/java_test_dags.py | 12 +
.../airflow_e2e_tests/e2e_test_utils/clients.py | 8 +
.../java_sdk_tests/test_java_sdk_dag.py | 56 ++++
.../main/kotlin/org/apache/airflow/sdk/Context.kt | 50 ++++
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 29 +-
.../apache/airflow/sdk/execution/Cancellation.kt | 134 ++++++++++
.../org/apache/airflow/sdk/execution/Logger.kt | 4 +
.../kotlin/org/apache/airflow/sdk/ContextTest.kt | 14 +
.../kotlin/org/apache/airflow/sdk/ServerTest.kt | 292 +++++++++++++++++++++
.../airflow/sdk/execution/CancellationTest.kt | 205 +++++++++++++++
.../apache/airflow/sdk/execution/LogSenderTest.kt | 94 +++++++
20 files changed, 1685 insertions(+), 168 deletions(-)
create mode 100644
airflow-core/src/airflow/migrations/versions/0148_3_4_0_add_pending_partition_key_to_apdr.py
create mode 100644
airflow-core/tests/unit/migrations/test_0148_add_pending_partition_key_to_apdr.py
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Cancellation.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/execution/CancellationTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/execution/LogSenderTest.kt
