This is an automated email from the ASF dual-hosted git repository.
vikramkoka pushed a change to branch aip99-aipdev-example
in repository https://gitbox.apache.org/repos/asf/airflow.git
from abbc745d606 Add AIP progress tracker example DAG for common.ai
provider
add 40a10b46add fix oudated img links in `dags.rst` (#67357)
add 9f5ee0f24a2 Remove Kaxil from codeowners for CI files (#67577)
add 129d03ed7a9 Go-SDK: Add coordinator-mode protocol primitives and SDK
surface hooks (#67315)
add 9aac9639dd2 Add new terms to spelling wordlist: newsfragments and
pyyaml (#67584)
add 44f7ee740db Add community escalation process doc with private@ appeal
channel (#67557)
add 27295a30d0f Disable otel collector by default (#67575)
add cb31b654e32 Add OpenLineage support to JdbcHook (#67457)
add 4ed546b1473 Recreate Supervisor Schema with Pydantic mechanism (#67596)
add 07859aaf32f feat(cli): add `partitions clear` to reset DagRun
partition fields (#66520)
add 6be0310f33e Replaced manual response descriptions with
create_openapi_http_exception_doc for Task Instance routes. This ensures
consistent OpenAPI documentation across the Execution API and removes redundant
hardcoded strings. (#62624)
add a2d5fa9c436 [main] CI: Upgrade important CI environment (#67593)
add 4eab62d40b7 Fix example_mwaa_serverless system test race condition
with stop_workflow_run (#67578)
add 5b126842b9a Fix GET /pools list endpoint incorrectly documenting 404
in OpenAPI spec (#67570)
add 647017278b6 Fix GET /auth/login missing 400 in OpenAPI spec and use
status constant (#67571)
add cd431eedcd0 Make session parameter in dag_clear CLI keyword only
(#67582)
add d9e5446aaac Avoid logging Execution API bearer credentials (#67059)
add 5151f6cd203 Fix SecretsMasker merge round-trip for Kubernetes env vars
(#67122)
add f08e118476e Add Coordinator Layer and Java Coordinator (#65958)
add 69686283690 Update providers metadata 2026-05-27 (#67611)
add 7bf71a3d444 Speed up TaskGroup.topological_sort with int-indexed
projected sweep (#67288)
add 03291c4e676 Add support for mTLS and private CAs to the api client /
server (#67214)
add 2ac00bbc27d Chart: add serviceAccountTokenVolume to cleanup cron
(#67446)
add 1e756428307 [main] CI: Upgrade important CI environment (#67613)
add 70257e69686 Reject wildcard origin in CORS config instead of toggling
credentials (#67502)
add f0f978d2736 Mask per-key secrets-backend-kwarg overrides on the Config
API (#67622)
add 1f5b99948a7 Add dynamic task mapping no-op example (#67022)
add 3276dded172 Add prek hook to enforce keyword-only `session` on
`@provide_session` (#67150)
add fd9241cdf0b Add `ResumableJobMixin` with `SparkSubmitOperator` as a
case study for surviving worker failures (standalone) (#67118)
add b66f4433e00 Guard finally-block logger.info in HTTP access log
middleware (#67501)
add 7f54b63eb9d UI: Add bulk Clear on the Dag Runs list page (#67564)
add f02d91e98a8 Fix compat test flakiness in SnowflakeSqlApiHook timeout
test (#67641)
add a8423447983 UI: Revert @chakra-ui/react bump that broke modal
dismissal (#67646)
add ba36e029c58 Add `consumer_teams` to `AssetAccessControl` in task-sdk
(#67625)
add fc845cf64c0 Write Cloud SQL keyfile_dict credentials with 0600
permissions (#67507)
add 23b334f29eb Add IBM MQ provider (#62790)
add 64dd5d6b429 Fix inconsistency in S3 transfer operators (#67378)
add 5898bcb2b92 Emit OpenTelemetry spans around listener hook calls
(#67347)
add fd950357d6b Fix KubernetesPodOperator emitting orphan timestamps for
empty container writes (#67652)
add a28b726798d Add AIP progress tracker example DAG for common.ai
provider
add 1f440f45841 Updated AIP-tracker example for common.ai
add 2aaab410ef5 Merge branch 'aip99-aipdev-example' of
https://github.com/apache/airflow into aip99-aipdev-example
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 3 +-
.github/ISSUE_TEMPLATE/1-airflow_bug_report.yml | 1 +
.github/boring-cyborg.yml | 3 +
.pre-commit-config.yaml | 10 +-
CODE_OF_CONDUCT.md | 6 +
COMMUNITY_ESCALATION.md | 146 +
Dockerfile | 2 +-
Dockerfile.ci | 4 +-
README.md | 17 +
.../dynamic-task-mapping.rst | 30 +
airflow-core/docs/best-practices.rst | 2 +-
airflow-core/docs/core-concepts/dags.rst | 14 +-
airflow-core/docs/extra-packages-ref.rst | 2 +
airflow-core/docs/security/api.rst | 10 +-
airflow-core/newsfragments/67288.improvement.rst | 1 +
airflow-core/pyproject.toml | 2 +-
.../airflow/api_fastapi/common/http_access_log.py | 24 +-
.../src/airflow/api_fastapi/core_api/app.py | 19 +-
.../api_fastapi/core_api/openapi/exceptions.py | 23 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 12 +-
.../api_fastapi/core_api/routes/public/auth.py | 6 +-
.../api_fastapi/core_api/routes/public/config.py | 9 +-
.../api_fastapi/core_api/routes/public/pools.py | 1 -
.../api_fastapi/core_api/services/public/config.py | 32 +
.../execution_api/routes/task_instances.py | 106 +-
.../airflow/api_fastapi/execution_api/security.py | 6 +-
.../src/airflow/api_fastapi/gunicorn_app.py | 10 +
airflow-core/src/airflow/cli/cli_config.py | 86 +
.../src/airflow/cli/commands/api_server_command.py | 30 +-
.../src/airflow/cli/commands/dag_command.py | 2 +-
.../src/airflow/cli/commands/partition_command.py | 171 +
.../src/airflow/config_templates/config.yml | 75 +-
.../src/airflow/dag_processing/processor.py | 14 +-
.../src/airflow/jobs/triggerer_job_runner.py | 12 +-
.../airflow/serialization/definitions/taskgroup.py | 97 +-
airflow-core/src/airflow/ui/CONTRIBUTING.md | 21 +
.../ui/openapi-gen/requests/services.gen.ts | 2 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 8 +-
airflow-core/src/airflow/ui/package.json | 2 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 1374 +++---
.../BulkClearDagRunsButton.tsx} | 98 +-
.../src/airflow/ui/src/pages/DagRuns/DagRuns.tsx | 2 +
.../airflow/ui/src/queries/useBulkClearDagRuns.ts | 181 +
.../ui/src/queries/useBulkClearDagRunsDryRun.ts | 82 +
airflow-core/tests/integration/otel/test_otel.py | 6 +-
.../tests/unit/always/test_example_dags.py | 1 +
.../api_fastapi/common/test_http_access_log.py | 52 +
.../core_api/routes/public/test_config.py | 67 +
.../tests/unit/api_fastapi/core_api/test_app.py | 35 +-
.../api_fastapi/execution_api/test_security.py | 42 +
.../unit/cli/commands/test_api_server_command.py | 38 +-
.../unit/cli/commands/test_gunicorn_monitor.py | 4 +
.../unit/cli/commands/test_partition_command.py | 968 ++++
.../tests/unit/dag_processing/test_processor.py | 4 +-
airflow-core/tests/unit/utils/test_task_group.py | 28 +
airflow-ctl-tests/pyproject.toml | 2 +-
airflow-ctl/pyproject.toml | 2 +-
airflow-e2e-tests/pyproject.toml | 2 +-
chart/docs/production-guide.rst | 4 +-
chart/pyproject.toml | 2 +-
chart/templates/_helpers.yaml | 51 +
chart/templates/cleanup/cleanup-cronjob.yaml | 3 +
.../templates/scheduler/scheduler-deployment.yaml | 30 +-
.../helm_tests/airflow_aux/test_airflow_common.py | 12 -
.../airflow_aux/test_basic_helm_chart.py | 9 +-
.../otel_collector/test_labels_deployment.py | 5 -
.../otel_collector/test_labels_networkpolicy.py | 4 -
.../otel_collector/test_labels_service.py | 4 -
.../otel_collector/test_labels_serviceaccount.py | 4 -
.../otel_collector/test_otel_collector.py | 284 +-
chart/tests/helm_tests/security/test_rbac.py | 16 +-
chart/values.schema.json | 41 +-
chart/values.yaml | 21 +-
clients/python/pyproject.toml | 2 +-
contributing-docs/02_how_to_communicate.rst | 5 +
contributing-docs/05_pull_requests.rst | 33 +-
contributing-docs/12_provider_distributions.rst | 13 +
contributing-docs/README.rst | 8 +
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/images/output_build-docs.svg | 6 +-
dev/breeze/doc/images/output_build-docs.txt | 2 +-
...tput_release-management_add-back-references.svg | 6 +-
...tput_release-management_add-back-references.txt | 2 +-
.../output_release-management_publish-docs.svg | 6 +-
.../output_release-management_publish-docs.txt | 2 +-
...output_sbom_generate-providers-requirements.svg | 2 +-
...output_sbom_generate-providers-requirements.txt | 2 +-
.../images/output_workflow-run_publish-docs.svg | 6 +-
.../images/output_workflow-run_publish-docs.txt | 2 +-
.../commands/release_management_commands.py | 2 +-
dev/breeze/src/airflow_breeze/global_constants.py | 2 +-
dev/breeze/tests/test_selective_checks.py | 4 +-
dev/breeze/uv.lock | 86 +-
dev/mypy/pyproject.toml | 2 +-
dev/pyproject.toml | 2 +-
dev/registry/pyproject.toml | 2 +-
devel-common/pyproject.toml | 2 +-
devel-common/src/docs/provider_conf.py | 2 +-
.../sphinx_exts/includes/sections-and-options.rst | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 17 +-
docker-stack-docs/pyproject.toml | 2 +-
docker-tests/pyproject.toml | 2 +-
docs/spelling_wordlist.txt | 12 +
generated/provider_metadata.json | 8 +
go-sdk/bundle/bundlev1/task.go | 7 +-
go-sdk/go.mod | 2 +
go-sdk/go.sum | 4 +
go-sdk/pkg/execution/frames.go | 286 ++
go-sdk/pkg/execution/frames_test.go | 258 +
go-sdk/pkg/execution/messages.go | 412 ++
go-sdk/pkg/execution/messages_test.go | 375 ++
go-sdk/pkg/sdkcontext/keys.go | 8 +
go-sdk/sdk/client.go | 15 +-
go-sdk/sdk/connection.go | 6 +-
go-sdk/sdk/sdk.go | 16 +
kubernetes-tests/pyproject.toml | 2 +-
providers-summary-docs/pyproject.toml | 2 +-
.../providers/amazon/aws/transfers/ftp_to_s3.py | 41 +-
.../providers/amazon/aws/transfers/s3_to_ftp.py | 80 +-
.../providers/amazon/aws/transfers/s3_to_sftp.py | 92 +-
.../providers/amazon/aws/transfers/sftp_to_s3.py | 148 +-
.../system/amazon/aws/example_mwaa_serverless.py | 35 +-
.../unit/amazon/aws/transfers/test_ftp_to_s3.py | 35 +
.../unit/amazon/aws/transfers/test_s3_to_ftp.py | 61 +-
.../unit/amazon/aws/transfers/test_s3_to_sftp.py | 62 +
.../unit/amazon/aws/transfers/test_sftp_to_s3.py | 104 +-
providers/apache/spark/docs/index.rst | 2 +
providers/apache/spark/docs/operators.rst | 21 +
providers/apache/spark/provider.yaml | 16 +
providers/apache/spark/pyproject.toml | 2 +
.../providers/apache/spark/get_provider_info.py | 10 +
.../providers/apache/spark/hooks/spark_submit.py | 52 +-
.../apache/spark/operators/spark_submit.py | 147 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 30 +
.../apache/spark/operators/test_spark_submit.py | 262 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 27 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 69 +
providers/common/ai/pyproject.toml | 2 +-
.../example_dags/example_aip_progress_tracker.py | 197 +-
providers/edge3/pyproject.toml | 2 +-
providers/fab/pyproject.toml | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 6 +-
.../unit/google/cloud/hooks/test_cloud_sql.py | 30 +
{airflow-core => providers/ibm/mq}/.gitignore | 0
LICENSE => providers/ibm/mq/LICENSE | 0
NOTICE => providers/ibm/mq/NOTICE | 0
providers/{redis => ibm/mq}/README.rst | 65 +-
.../mq}/docs/.latest-doc-only-change.txt | 0
providers/{vespa => ibm/mq}/docs/changelog.rst | 9 +-
providers/{asana => ibm/mq}/docs/commits.rst | 6 +-
providers/{imap => ibm/mq}/docs/conf.py | 2 +-
.../mq/docs/connections/ibmmq.rst} | 14 +-
.../mq/docs/connections/images/mq_connection.png | Bin 0 -> 31251 bytes
providers/{redis => ibm/mq}/docs/index.rst | 53 +-
.../mq}/docs/installing-providers-from-sources.rst | 0
providers/ibm/mq/docs/integration-logos/ibm-mq.png | Bin 0 -> 67759 bytes
providers/ibm/mq/docs/message-queues.rst | 100 +
providers/ibm/mq/docs/redirects.txt | 1 +
.../{apache/beam => ibm/mq}/docs/security.rst | 0
.../ibm/mq/pre_extras_install.yaml | 35 +-
.../bundles => providers/ibm/mq}/provider.yaml | 49 +-
providers/{redis => ibm/mq}/pyproject.toml | 25 +-
.../ibm/mq/src/airflow}/__init__.py | 2 +-
.../ibm/mq/src/airflow/providers}/__init__.py | 2 +-
.../ibm/mq/src/airflow/providers/ibm}/__init__.py | 2 +-
.../mq/src/airflow/providers/ibm/mq}/__init__.py | 4 +-
.../airflow/providers/ibm/mq}/get_provider_info.py | 34 +-
.../airflow/providers/ibm/mq/hooks}/__init__.py | 0
.../mq/src/airflow/providers/ibm/mq/hooks/mq.py | 708 +++
.../airflow/providers/ibm/mq/queues}/__init__.py | 0
.../mq/src/airflow/providers/ibm/mq/queues/mq.py | 137 +
.../airflow/providers/ibm/mq/triggers}/__init__.py | 0
.../mq/src/airflow/providers/ibm/mq/triggers/mq.py | 80 +
.../airflow/providers/ibm/mq}/version_compat.py | 0
providers/ibm/mq/tests/conftest.py | 120 +
.../ibm/mq/tests/system}/__init__.py | 2 +-
.../ibm/mq/tests/system/ibm}/__init__.py | 2 +-
.../ibm/mq/tests/system/ibm/mq}/__init__.py | 0
.../ibm/mq}/example_dag_message_queue_trigger.py | 37 +-
.../ibm/mq/tests/unit}/__init__.py | 2 +-
.../ibm/mq/tests/unit/ibm}/__init__.py | 2 +-
.../ibm/mq/tests/unit/ibm/mq}/__init__.py | 0
.../ibm/mq/tests/unit/ibm/mq/hooks}/__init__.py | 0
.../ibm/mq/tests/unit/ibm/mq/hooks/test_mq.py | 1150 +++++
.../ibm/mq/tests/unit/ibm/mq/queues}/__init__.py | 0
.../ibm/mq/tests/unit/ibm/mq/queues/test_mq.py | 249 +
.../ibm/mq/tests/unit/ibm/mq/triggers}/__init__.py | 0
.../ibm/mq/tests/unit/ibm/mq/triggers/test_mq.py | 76 +
providers/jdbc/docs/index.rst | 1 +
providers/jdbc/pyproject.toml | 8 +
.../jdbc/src/airflow/providers/jdbc/hooks/jdbc.py | 82 +
providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 152 +
.../unit/snowflake/hooks/test_snowflake_sql_api.py | 11 +-
pyproject.toml | 24 +-
scripts/ci/docker-compose/remove-sources.yml | 1 +
scripts/ci/docker-compose/tests-sources.yml | 1 +
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_provide_session_kwargs.py | 427 ++
.../ci/prek/check_supervisor_schemas_versions.py | 1 +
scripts/ci/prek/dump_supervisor_schemas.py | 48 +-
.../prek/generate_supervisor_schemas_snapshot.py | 1 +
scripts/ci/prek/known_airflow_exceptions.txt | 2 +-
.../ci/prek/known_provide_session_positional.txt | 89 +
scripts/ci/prek/ruff_format.py | 2 +-
scripts/docker/entrypoint_ci.sh | 2 +-
scripts/in_container/run_pre_extras_install.py | 94 +-
scripts/pyproject.toml | 2 +-
.../ci/prek/test_check_provide_session_kwargs.py | 482 ++
scripts/tools/setup_breeze | 2 +-
shared/configuration/pyproject.toml | 2 +-
shared/dagnode/pyproject.toml | 2 +-
shared/listeners/pyproject.toml | 5 +-
.../src/airflow_shared/listeners/listener.py | 48 +-
.../tests/listeners/test_listener_manager.py | 95 +-
shared/logging/pyproject.toml | 2 +-
shared/module_loading/pyproject.toml | 2 +-
shared/observability/pyproject.toml | 2 +-
shared/plugins_manager/pyproject.toml | 2 +-
shared/providers_discovery/pyproject.toml | 2 +-
shared/secrets_backend/pyproject.toml | 2 +-
shared/secrets_masker/pyproject.toml | 2 +-
.../secrets_masker/secrets_masker.py | 8 +
.../tests/secrets_masker/test_secrets_masker.py | 35 +
shared/serialization/pyproject.toml | 2 +-
shared/state/pyproject.toml | 2 +-
shared/template_rendering/pyproject.toml | 2 +-
shared/timezones/pyproject.toml | 2 +-
task-sdk-integration-tests/pyproject.toml | 2 +-
task-sdk/.pre-commit-config.yaml | 4 +-
task-sdk/docs/api.rst | 2 +
task-sdk/pyproject.toml | 2 +-
task-sdk/src/airflow/sdk/__init__.py | 3 +
task-sdk/src/airflow/sdk/api/client.py | 18 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 8 +
task-sdk/src/airflow/sdk/bases/resumablemixin.py | 167 +
.../src/airflow/sdk/coordinators/java}/__init__.py | 11 +-
.../airflow/sdk/coordinators/java/coordinator.py | 424 ++
.../sdk/definitions/asset/access_control.py | 10 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 125 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 7 +-
.../src/airflow/sdk/execution_time/coordinator.py | 246 +
.../airflow/sdk/execution_time/schema/schema.json | 5209 ++++++++------------
.../src/airflow/sdk/execution_time/supervisor.py | 179 +-
.../src/airflow/sdk/execution_time/task_runner.py | 3 +-
task-sdk/tests/task_sdk/api/test_client.py | 19 +
.../tests/task_sdk/bases/test_resumablemixin.py | 177 +
.../tests/task_sdk/coordinators}/__init__.py | 0
.../tests/task_sdk/coordinators/java}/__init__.py | 0
.../task_sdk/coordinators/java/test_coordinator.py | 759 +++
.../definitions/test_asset_access_control.py | 37 +-
.../task_sdk/definitions/test_mappedoperator.py | 4 +-
.../tests/task_sdk/definitions/test_taskgroup.py | 144 +
.../tests/task_sdk/definitions/test_xcom_arg.py | 2 +-
task-sdk/tests/task_sdk/docs/test_public_api.py | 21 +-
.../tests/task_sdk/execution_time/test_comms.py | 3 +
.../task_sdk/execution_time/test_coordinator.py | 122 +
.../task_sdk/execution_time/test_supervisor.py | 242 +-
.../task_sdk/execution_time/test_task_runner.py | 89 +-
uv.lock | 555 ++-
259 files changed, 15554 insertions(+), 5332 deletions(-)
create mode 100644 COMMUNITY_ESCALATION.md
create mode 100644 airflow-core/newsfragments/67288.improvement.rst
create mode 100644 airflow-core/src/airflow/cli/commands/partition_command.py
copy
airflow-core/src/airflow/ui/src/pages/{TaskInstances/BulkClearTaskInstancesButton.tsx
=> DagRuns/BulkClearDagRunsButton.tsx} (50%)
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkClearDagRuns.ts
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkClearDagRunsDryRun.ts
create mode 100644
airflow-core/tests/unit/cli/commands/test_partition_command.py
create mode 100644 go-sdk/pkg/execution/frames.go
create mode 100644 go-sdk/pkg/execution/frames_test.go
create mode 100644 go-sdk/pkg/execution/messages.go
create mode 100644 go-sdk/pkg/execution/messages_test.go
copy {airflow-core => providers/ibm/mq}/.gitignore (100%)
copy LICENSE => providers/ibm/mq/LICENSE (100%)
copy NOTICE => providers/ibm/mq/NOTICE (100%)
copy providers/{redis => ibm/mq}/README.rst (55%)
copy providers/{apache/beam => ibm/mq}/docs/.latest-doc-only-change.txt (100%)
copy providers/{vespa => ibm/mq}/docs/changelog.rst (78%)
copy providers/{asana => ibm/mq}/docs/commits.rst (93%)
copy providers/{imap => ibm/mq}/docs/conf.py (99%)
copy providers/{slack/docs/connections/index.rst =>
ibm/mq/docs/connections/ibmmq.rst} (76%)
create mode 100644 providers/ibm/mq/docs/connections/images/mq_connection.png
copy providers/{redis => ibm/mq}/docs/index.rst (70%)
copy providers/{apache/beam =>
ibm/mq}/docs/installing-providers-from-sources.rst (100%)
create mode 100644 providers/ibm/mq/docs/integration-logos/ibm-mq.png
create mode 100644 providers/ibm/mq/docs/message-queues.rst
create mode 100644 providers/ibm/mq/docs/redirects.txt
copy providers/{apache/beam => ibm/mq}/docs/security.rst (100%)
copy chart/tests/helm_tests/other/test_limit_ranges.py =>
providers/ibm/mq/pre_extras_install.yaml (53%)
copy {airflow-core/src/airflow/dag_processing/bundles =>
providers/ibm/mq}/provider.yaml (56%)
copy providers/{redis => ibm/mq}/pyproject.toml (88%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/src/airflow}/__init__.py (98%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/src/airflow/providers}/__init__.py (98%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/src/airflow/providers/ibm}/__init__.py (98%)
copy providers/{openai/src/airflow/providers/openai =>
ibm/mq/src/airflow/providers/ibm/mq}/__init__.py (94%)
copy providers/{git/src/airflow/providers/git =>
ibm/mq/src/airflow/providers/ibm/mq}/get_provider_info.py (56%)
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/src/airflow/providers/ibm/mq/hooks}/__init__.py (100%)
create mode 100644 providers/ibm/mq/src/airflow/providers/ibm/mq/hooks/mq.py
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/src/airflow/providers/ibm/mq/queues}/__init__.py (100%)
create mode 100644 providers/ibm/mq/src/airflow/providers/ibm/mq/queues/mq.py
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/src/airflow/providers/ibm/mq/triggers}/__init__.py (100%)
create mode 100644 providers/ibm/mq/src/airflow/providers/ibm/mq/triggers/mq.py
copy providers/{apache/flink/src/airflow/providers/apache/flink =>
ibm/mq/src/airflow/providers/ibm/mq}/version_compat.py (100%)
create mode 100644 providers/ibm/mq/tests/conftest.py
copy {airflow-core/tests/integration =>
providers/ibm/mq/tests/system}/__init__.py (98%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/tests/system/ibm}/__init__.py (98%)
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/tests/system/ibm/mq}/__init__.py (100%)
copy providers/{apache/kafka/tests/system/apache/kafka =>
ibm/mq/tests/system/ibm/mq}/example_dag_message_queue_trigger.py (57%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/tests/unit}/__init__.py (98%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/tests/unit/ibm}/__init__.py (98%)
copy {airflow-core/tests/integration =>
providers/ibm/mq/tests/unit/ibm/mq}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/tests/unit/ibm/mq/hooks}/__init__.py (100%)
create mode 100644 providers/ibm/mq/tests/unit/ibm/mq/hooks/test_mq.py
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/tests/unit/ibm/mq/queues}/__init__.py (100%)
create mode 100644 providers/ibm/mq/tests/unit/ibm/mq/queues/test_mq.py
copy {airflow-core/src/airflow/_shared =>
providers/ibm/mq/tests/unit/ibm/mq/triggers}/__init__.py (100%)
create mode 100644 providers/ibm/mq/tests/unit/ibm/mq/triggers/test_mq.py
create mode 100755 scripts/ci/prek/check_provide_session_kwargs.py
create mode 100644 scripts/ci/prek/known_provide_session_positional.txt
create mode 100644 scripts/tests/ci/prek/test_check_provide_session_kwargs.py
create mode 100644 task-sdk/src/airflow/sdk/bases/resumablemixin.py
copy {airflow-ctl-tests/tests/airflowctl_tests =>
task-sdk/src/airflow/sdk/coordinators/java}/__init__.py (79%)
create mode 100644 task-sdk/src/airflow/sdk/coordinators/java/coordinator.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/coordinator.py
create mode 100644 task-sdk/tests/task_sdk/bases/test_resumablemixin.py
copy {airflow-core/src/airflow/_shared =>
task-sdk/tests/task_sdk/coordinators}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
task-sdk/tests/task_sdk/coordinators/java}/__init__.py (100%)
create mode 100644
task-sdk/tests/task_sdk/coordinators/java/test_coordinator.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_coordinator.py
