This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/core-ui-package-updates-4677d33891
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard c8c66b3dd2a Bump the core-ui-package-updates group across 1 directory
with 15 updates
add 90e12279ca2 Refactor JobState enum across Airflow components (#53387)
add e492399740d Move the DAG cycle tests from core to task sdk (#54225)
add dcdbcadfffc chore: change openlineage to optional dependency (#54748)
add a51a60423d5 Potential fix for code scanning alert no. 519: Clear-text
logging of sensitive information (#54742)
add fdd6d3ed746 Remove portalocker dependency (#54751)
add f3fec1b3b9a Update main with Airflow 3.0.5 release details (#54754)
add bcdfee4671b Chart: Update Default Airflow image to 3.0.5 (#54755)
add 612e9e31293 fix helm schema validation for executor value (#54682)
add 7a3c9a994f5 Add rudimentary support for psycopg3 (#52976)
add 0204a890791 Fix AF3 TriggerDagRunLink to handle combinations of
base_url (#54218)
add bd6020b0b3c Move trigger_rule utils from `airflow/utils` to
`airflow.task`and integrate with Execution API spec (#53389)
add 743711d08e4 Adding validation for missing conn_type while constructing
connections (#54759)
add 00b3b14f02a Fix typos in HITL-related code and comments (#54670)
add 5aec867d3c4 Ensure that Connection extra can get masked without
causing an error (#54769)
add 9c1f36835d5 Made get_conn method async for KiotaRequestAdapterHook to
fix AsyncToSync error (#54598)
add 4703ebe6c48 Run compat test with 3.0.4 (#54776)
add f7f32544726 XCom value copy option Position Change to Right (#54765)
add 42f6e28f351 Skip provider_session usage in AF3 for BigQuery and
Dataproc triggers (#54405)
add 10d3091ab7a Fix CloudComposerDAGRunSensor functionality (#54351)
add 0597df5d93c Fix sftp async hoook (#54763)
add df0aa3fbe1f feature: Add OpenLineage support for
PubSubPublishMessageOperator (#54764)
add a6b5baa1696 Small adjustments to Audit Logs filtering (#54671)
add 9652ed94413 feat(ui): Add Turkish Translation for the UI and CODEOWNER
(#51266)
add 8ffff1500d6 Bump the core-ui-package-updates group across 1 directory
with 15 updates
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 (c8c66b3dd2a)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/core-ui-package-updates-4677d33891
(8ffff1500d6)
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:
.github/CODEOWNERS | 1 +
.github/ISSUE_TEMPLATE/1-airflow_bug_report.yml | 2 +-
.github/boring-cyborg.yml | 3 +
Dockerfile | 2 +-
README.md | 14 +-
RELEASE_NOTES.rst | 59 ++
.../docs/installation/supported-versions.rst | 2 +-
.../auth/managers/simple/ui/package-lock.json | 262 ++---
.../auth/managers/simple/ui/package.json | 2 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 266 +++---
.../api_fastapi/core_api/routes/public/job.py | 3 +-
.../src/airflow/api_fastapi/execution_api/app.py | 2 +
airflow-core/src/airflow/cli/cli_config.py | 3 +-
.../src/airflow/cli/commands/jobs_command.py | 3 +-
.../example_latest_only_with_trigger.py | 3 +-
.../example_dags/example_nested_branch_dag.py | 3 +-
.../example_dags/example_params_trigger_ui.py | 3 +-
.../src/airflow/example_dags/example_skip_dag.py | 3 +-
airflow-core/src/airflow/exceptions.py | 21 -
airflow-core/src/airflow/jobs/job.py | 15 +-
.../src/airflow/jobs/scheduler_job_runner.py | 4 +-
.../airflow/serialization/serialized_objects.py | 2 +-
airflow-core/src/airflow/settings.py | 27 +-
.../src/airflow/{utils => task}/trigger_rule.py | 0
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 2 +-
.../airflow/ui/public/i18n/locales/tr/admin.json | 167 ++++
.../airflow/ui/public/i18n/locales/tr/assets.json | 30 +
.../airflow/ui/public/i18n/locales/tr/browse.json | 26 +
.../airflow/ui/public/i18n/locales/tr/common.json | 314 ++++++
.../ui/public/i18n/locales/tr/components.json | 136 +++
.../src/airflow/ui/public/i18n/locales/tr/dag.json | 122 +++
.../airflow/ui/public/i18n/locales/tr/dags.json | 97 ++
.../ui/public/i18n/locales/tr/dashboard.json | 45 +
.../airflow/ui/public/i18n/locales/tr/hitl.json | 24 +
airflow-core/src/airflow/ui/src/i18n/config.ts | 1 +
.../airflow/ui/src/pages/Events/EventsFilters.tsx | 34 +-
.../Events/filterUtils.ts} | 71 +-
.../src/airflow/ui/src/pages/XCom/XComEntry.tsx | 10 +-
airflow-core/src/airflow/utils/__init__.py | 4 +
airflow-core/src/airflow/utils/db.py | 34 +-
airflow-core/src/airflow/utils/helpers.py | 2 +-
airflow-core/src/airflow/utils/state.py | 12 -
airflow-core/tests/unit/always/test_connection.py | 23 +-
.../api_fastapi/core_api/routes/public/test_job.py | 4 +-
.../tests/unit/cli/commands/test_db_command.py | 52 +
.../tests/unit/cli/commands/test_jobs_command.py | 4 +-
.../tests/unit/core/test_example_dags_system.py | 2 +-
.../tests/unit/decorators/test_task_group.py | 2 +-
airflow-core/tests/unit/models/test_dag.py | 39 +-
airflow-core/tests/unit/models/test_dagrun.py | 2 +-
.../tests/unit/models/test_mappedoperator.py | 2 +-
.../unit/serialization/test_dag_serialization.py | 2 +-
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 2 +-
airflow-core/tests/unit/utils/test_dag_cycle.py | 167 ----
airflow-core/tests/unit/utils/test_trigger_rule.py | 2 +-
chart/Chart.yaml | 18 +-
chart/newsfragments/53350.significant.rst | 4 +-
chart/values.schema.json | 6 +-
chart/values.yaml | 4 +-
devel-common/src/docs/utils/conf_constants.py | 1 +
devel-common/src/tests_common/pytest_plugin.py | 3 +-
devel-common/src/tests_common/test_utils/compat.py | 7 +
.../src/tests_common/test_utils/watcher.py | 7 +-
docs/spelling_wordlist.txt | 1 +
generated/PYPI_README.md | 10 +-
.../airflow_aux/test_basic_helm_chart.py | 15 +-
.../performance_dag/performance_dag.py | 7 +-
performance/tests/test_performance_dag.py | 7 +-
.../tests/system/amazon/aws/example_appflow_run.py | 6 +-
.../tests/system/amazon/aws/example_athena.py | 6 +-
.../system/amazon/aws/example_azure_blob_to_s3.py | 6 +-
.../tests/system/amazon/aws/example_batch.py | 6 +-
.../tests/system/amazon/aws/example_bedrock.py | 6 +-
.../amazon/aws/example_bedrock_batch_inference.py | 6 +-
.../aws/example_bedrock_retrieve_and_generate.py | 6 +-
.../system/amazon/aws/example_cloudformation.py | 6 +-
.../tests/system/amazon/aws/example_comprehend.py | 6 +-
.../aws/example_comprehend_document_classifier.py | 6 +-
.../tests/system/amazon/aws/example_datasync.py | 6 +-
.../amazon/tests/system/amazon/aws/example_dms.py | 6 +-
.../system/amazon/aws/example_dms_serverless.py | 6 +-
.../tests/system/amazon/aws/example_dynamodb.py | 6 +-
.../system/amazon/aws/example_dynamodb_to_s3.py | 6 +-
.../amazon/tests/system/amazon/aws/example_ec2.py | 6 +-
.../amazon/tests/system/amazon/aws/example_ecs.py | 6 +-
.../tests/system/amazon/aws/example_ecs_fargate.py | 6 +-
.../aws/example_eks_with_fargate_in_one_step.py | 6 +-
.../amazon/aws/example_eks_with_fargate_profile.py | 6 +-
.../aws/example_eks_with_nodegroup_in_one_step.py | 6 +-
.../amazon/aws/example_eks_with_nodegroups.py | 6 +-
.../amazon/tests/system/amazon/aws/example_emr.py | 6 +-
.../tests/system/amazon/aws/example_emr_eks.py | 6 +-
.../system/amazon/aws/example_emr_serverless.py | 6 +-
.../tests/system/amazon/aws/example_ftp_to_s3.py | 6 +-
.../tests/system/amazon/aws/example_gcs_to_s3.py | 6 +-
.../system/amazon/aws/example_glacier_to_gcs.py | 6 +-
.../amazon/tests/system/amazon/aws/example_glue.py | 6 +-
.../system/amazon/aws/example_glue_data_quality.py | 6 +-
...xample_glue_data_quality_with_recommendation.py | 6 +-
.../system/amazon/aws/example_glue_databrew.py | 6 +-
.../amazon/aws/example_google_api_sheets_to_s3.py | 6 +-
.../amazon/aws/example_google_api_youtube_to_s3.py | 6 +-
.../system/amazon/aws/example_hive_to_dynamodb.py | 6 +-
.../tests/system/amazon/aws/example_http_to_s3.py | 6 +-
.../amazon/aws/example_imap_attachment_to_s3.py | 6 +-
.../system/amazon/aws/example_kinesis_analytics.py | 6 +-
.../tests/system/amazon/aws/example_lambda.py | 6 +-
.../tests/system/amazon/aws/example_local_to_s3.py | 6 +-
.../tests/system/amazon/aws/example_mongo_to_s3.py | 6 +-
.../tests/system/amazon/aws/example_quicksight.py | 6 +-
.../tests/system/amazon/aws/example_rds_event.py | 6 +-
.../tests/system/amazon/aws/example_rds_export.py | 6 +-
.../system/amazon/aws/example_rds_instance.py | 6 +-
.../system/amazon/aws/example_rds_snapshot.py | 6 +-
.../tests/system/amazon/aws/example_redshift.py | 6 +-
.../amazon/aws/example_redshift_s3_transfers.py | 6 +-
.../amazon/tests/system/amazon/aws/example_s3.py | 6 +-
.../system/amazon/aws/example_s3_to_dynamodb.py | 6 +-
.../tests/system/amazon/aws/example_s3_to_ftp.py | 6 +-
.../tests/system/amazon/aws/example_s3_to_sftp.py | 6 +-
.../tests/system/amazon/aws/example_s3_to_sql.py | 6 +-
.../tests/system/amazon/aws/example_sagemaker.py | 6 +-
.../amazon/aws/example_sagemaker_endpoint.py | 6 +-
.../amazon/aws/example_sagemaker_pipeline.py | 6 +-
.../system/amazon/aws/example_salesforce_to_s3.py | 6 +-
.../tests/system/amazon/aws/example_sftp_to_s3.py | 6 +-
.../amazon/tests/system/amazon/aws/example_sns.py | 6 +-
.../tests/system/amazon/aws/example_sql_to_s3.py | 6 +-
.../amazon/tests/system/amazon/aws/example_sqs.py | 6 +-
.../amazon/tests/system/amazon/aws/example_ssm.py | 7 +-
.../amazon/aws/tests/test_lambda_executor_dlq.py | 6 +-
.../tests/system/amazon/aws/utils/__init__.py | 7 +-
.../amazon/tests/system/amazon/aws/utils/ec2.py | 6 +-
.../apache/beam/tests/system/apache/beam/utils.py | 6 +-
.../common/io/example_file_transfer_local_to_s3.py | 7 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 3 +
.../sql/tests/unit/common/sql/sensors/test_sql.py | 4 +-
providers/databricks/pyproject.toml | 4 +-
.../edge3/example_dags/integration_test.py | 6 +-
.../providers/edge3/example_dags/win_test.py | 7 +-
.../fab/auth_manager/security_manager/override.py | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 6 +-
.../providers/google/cloud/operators/pubsub.py | 17 +-
.../google/cloud/sensors/cloud_composer.py | 5 +
.../google/cloud/transfers/postgres_to_gcs.py | 51 +-
.../providers/google/cloud/triggers/bigquery.py | 42 +-
.../google/cloud/triggers/cloud_composer.py | 6 +
.../providers/google/cloud/triggers/dataproc.py | 86 +-
.../google/tests/system/google/ads/example_ads.py | 7 +-
.../google/cloud/alloy_db/example_alloy_db.py | 7 +-
.../cloud/azure/example_azure_fileshare_to_gcs.py | 7 +-
.../cloud/bigquery/example_bigquery_dataset.py | 7 +-
.../google/cloud/bigquery/example_bigquery_dts.py | 7 +-
.../google/cloud/bigquery/example_bigquery_jobs.py | 7 +-
.../cloud/bigquery/example_bigquery_operations.py | 7 +-
.../cloud/bigquery/example_bigquery_queries.py | 7 +-
.../bigquery/example_bigquery_queries_async.py | 7 +-
.../cloud/bigquery/example_bigquery_sensors.py | 7 +-
.../cloud/bigquery/example_bigquery_tables.py | 7 +-
.../cloud/bigquery/example_bigquery_to_bigquery.py | 7 +-
.../cloud/bigquery/example_bigquery_to_gcs.py | 7 +-
.../cloud/bigquery/example_bigquery_to_mssql.py | 7 +-
.../cloud/bigquery/example_bigquery_to_postgres.py | 7 +-
.../cloud/bigquery/example_bigquery_transfer.py | 7 +-
.../cloud/bigquery/example_bigquery_value_check.py | 7 +-
.../google/cloud/bigtable/example_bigtable.py | 7 +-
.../cloud/cloud_batch/example_cloud_batch.py | 7 +-
.../cloud_build/example_cloud_build_trigger.py | 7 +-
.../example_cloud_memorystore_memcached.py | 7 +-
.../example_cloud_memorystore_redis.py | 7 +-
.../google/cloud/cloud_run/example_cloud_run.py | 7 +-
.../google/cloud/cloud_sql/example_cloud_sql.py | 7 +-
.../cloud/cloud_sql/example_cloud_sql_query.py | 7 +-
.../cloud/cloud_sql/example_cloud_sql_query_iam.py | 7 +-
.../cloud/cloud_sql/example_cloud_sql_query_ssl.py | 7 +-
.../cloud/composer/example_cloud_composer.py | 7 +-
.../system/google/cloud/compute/example_compute.py | 7 +-
.../google/cloud/compute/example_compute_igm.py | 7 +-
.../google/cloud/compute/example_compute_ssh.py | 7 +-
.../cloud/compute/example_compute_ssh_os_login.py | 7 +-
.../cloud/compute/example_compute_ssh_parallel.py | 7 +-
.../example_dlp_deidentify_content.py | 7 +-
.../data_loss_prevention/example_dlp_info_types.py | 7 +-
.../example_dlp_inspect_template.py | 7 +-
.../cloud/data_loss_prevention/example_dlp_job.py | 7 +-
.../example_dlp_job_trigger.py | 7 +-
.../google/cloud/dataflow/example_dataflow_go.py | 7 +-
.../dataflow/example_dataflow_java_streaming.py | 7 +-
.../cloud/dataflow/example_dataflow_native_java.py | 7 +-
.../dataflow/example_dataflow_native_python.py | 7 +-
.../example_dataflow_native_python_async.py | 7 +-
.../cloud/dataflow/example_dataflow_pipeline.py | 7 +-
.../example_dataflow_sensors_deferrable.py | 7 +-
.../dataflow/example_dataflow_streaming_python.py | 7 +-
.../cloud/dataflow/example_dataflow_template.py | 7 +-
.../google/cloud/dataflow/example_dataflow_yaml.py | 7 +-
.../google/cloud/dataform/example_dataform.py | 7 +-
.../google/cloud/datafusion/example_datafusion.py | 7 +-
.../google/cloud/dataplex/example_dataplex.py | 7 +-
.../cloud/dataplex/example_dataplex_catalog.py | 7 +-
.../google/cloud/dataplex/example_dataplex_dp.py | 7 +-
.../google/cloud/dataplex/example_dataplex_dq.py | 7 +-
.../google/cloud/dataprep/example_dataprep.py | 7 +-
.../cloud/dataproc/example_dataproc_batch.py | 7 +-
.../dataproc/example_dataproc_batch_deferrable.py | 7 +-
.../dataproc/example_dataproc_batch_persistent.py | 7 +-
...proc_cluster_create_existing_stopped_cluster.py | 7 +-
.../example_dataproc_cluster_deferrable.py | 7 +-
.../dataproc/example_dataproc_cluster_diagnose.py | 7 +-
.../dataproc/example_dataproc_cluster_generator.py | 7 +-
.../example_dataproc_cluster_start_stop.py | 7 +-
.../dataproc/example_dataproc_cluster_update.py | 7 +-
.../cloud/dataproc/example_dataproc_flink.py | 7 +-
.../google/cloud/dataproc/example_dataproc_gke.py | 7 +-
.../cloud/dataproc/example_dataproc_hadoop.py | 7 +-
.../google/cloud/dataproc/example_dataproc_hive.py | 7 +-
.../google/cloud/dataproc/example_dataproc_pig.py | 7 +-
.../cloud/dataproc/example_dataproc_presto.py | 7 +-
.../cloud/dataproc/example_dataproc_pyspark.py | 7 +-
.../cloud/dataproc/example_dataproc_spark.py | 7 +-
.../cloud/dataproc/example_dataproc_spark_async.py | 7 +-
.../dataproc/example_dataproc_spark_deferrable.py | 7 +-
.../cloud/dataproc/example_dataproc_spark_sql.py | 7 +-
.../cloud/dataproc/example_dataproc_sparkr.py | 7 +-
.../cloud/dataproc/example_dataproc_trino.py | 7 +-
.../example_dataproc_metastore.py | 7 +-
.../example_dataproc_metastore_backup.py | 7 +-
...ple_dataproc_metastore_hive_partition_sensor.py | 7 +-
.../cloud/datastore/example_datastore_commit.py | 7 +-
.../google/cloud/gcs/example_calendar_to_gcs.py | 7 +-
.../system/google/cloud/gcs/example_firestore.py | 7 +-
.../system/google/cloud/gcs/example_gcs_acl.py | 7 +-
.../google/cloud/gcs/example_gcs_copy_delete.py | 7 +-
.../system/google/cloud/gcs/example_gcs_sensor.py | 7 +-
.../google/cloud/gcs/example_gcs_to_bigquery.py | 7 +-
.../cloud/gcs/example_gcs_to_bigquery_async.py | 7 +-
.../system/google/cloud/gcs/example_gcs_to_gcs.py | 7 +-
.../google/cloud/gcs/example_gcs_to_gdrive.py | 7 +-
.../system/google/cloud/gcs/example_gcs_to_sftp.py | 7 +-
.../google/cloud/gcs/example_gcs_to_sheets.py | 7 +-
.../google/cloud/gcs/example_gcs_transform.py | 7 +-
.../cloud/gcs/example_gcs_transform_timespan.py | 7 +-
.../cloud/gcs/example_gcs_upload_download.py | 7 +-
.../google/cloud/gcs/example_gdrive_to_gcs.py | 7 +-
.../system/google/cloud/gcs/example_http_to_gcs.py | 7 +-
.../google/cloud/gcs/example_mssql_to_gcs.py | 6 +-
.../google/cloud/gcs/example_mysql_to_gcs.py | 7 +-
.../google/cloud/gcs/example_oracle_to_gcs.py | 7 +-
.../google/cloud/gcs/example_presto_to_gcs.py | 7 +-
.../system/google/cloud/gcs/example_s3_to_gcs.py | 7 +-
.../google/cloud/gcs/example_salesforce_to_gcs.py | 7 +-
.../system/google/cloud/gcs/example_sftp_to_gcs.py | 7 +-
.../system/google/cloud/gcs/example_sheets.py | 7 +-
.../google/cloud/gcs/example_sheets_to_gcs.py | 7 +-
.../google/cloud/gcs/example_trino_to_gcs.py | 7 +-
.../kubernetes_engine/example_kubernetes_engine.py | 7 +-
.../example_kubernetes_engine_async.py | 7 +-
.../example_kubernetes_engine_job.py | 7 +-
.../example_kubernetes_engine_kueue.py | 7 +-
.../example_kubernetes_engine_ray.py | 7 +-
.../example_kubernetes_engine_resource.py | 7 +-
.../managed_kafka/example_managed_kafka_cluster.py | 7 +-
.../example_managed_kafka_consumer_group.py | 7 +-
.../managed_kafka/example_managed_kafka_topic.py | 7 +-
.../google/cloud/ml_engine/example_mlengine.py | 7 +-
.../system/google/cloud/pubsub/example_pubsub.py | 7 +-
.../cloud/pubsub/example_pubsub_deferrable.py | 7 +-
.../system/google/cloud/spanner/example_spanner.py | 7 +-
.../cloud/speech_to_text/example_speech_to_text.py | 7 +-
.../cloud/sql_to_sheets/example_sql_to_sheets.py | 7 +-
.../cloud/stackdriver/example_stackdriver.py | 7 +-
.../example_cloud_storage_transfer_service_aws.py | 7 +-
.../example_cloud_storage_transfer_service_gcp.py | 7 +-
...le_cloud_storage_transfer_service_gcs_to_gcs.py | 7 +-
.../system/google/cloud/tasks/example_queue.py | 7 +-
.../system/google/cloud/tasks/example_tasks.py | 7 +-
.../cloud/text_to_speech/example_text_to_speech.py | 7 +-
.../cloud/transfers/example_facebook_ads_to_gcs.py | 7 +-
.../google/cloud/transfers/example_gcs_to_sftp.py | 7 +-
.../cloud/transfers/example_gdrive_to_local.py | 7 +-
.../cloud/transfers/example_postgres_to_gcs.py | 7 +-
.../cloud/translate/example_translate_dataset.py | 7 +-
.../cloud/translate/example_translate_document.py | 7 +-
.../cloud/translate/example_translate_model.py | 7 +-
.../cloud/translate/example_translate_text.py | 7 +-
.../translate_speech/example_translate_speech.py | 7 +-
...ample_vertex_ai_auto_ml_forecasting_training.py | 7 +-
...ple_vertex_ai_auto_ml_image_object_detection.py | 7 +-
.../example_vertex_ai_auto_ml_image_training.py | 7 +-
.../example_vertex_ai_auto_ml_tabular_training.py | 7 +-
.../example_vertex_ai_auto_ml_video_tracking.py | 7 +-
.../example_vertex_ai_auto_ml_video_training.py | 7 +-
.../example_vertex_ai_batch_prediction_job.py | 7 +-
.../example_vertex_ai_custom_container.py | 7 +-
.../vertex_ai/example_vertex_ai_custom_job.py | 7 +-
.../example_vertex_ai_custom_job_python_package.py | 7 +-
.../cloud/vertex_ai/example_vertex_ai_dataset.py | 7 +-
.../cloud/vertex_ai/example_vertex_ai_endpoint.py | 7 +-
.../vertex_ai/example_vertex_ai_feature_store.py | 7 +-
.../example_vertex_ai_hyperparameter_tuning_job.py | 7 +-
.../vertex_ai/example_vertex_ai_model_service.py | 7 +-
.../vertex_ai/example_vertex_ai_pipeline_job.py | 7 +-
.../cloud/vertex_ai/example_vertex_ai_ray.py | 7 +-
.../example_video_intelligence.py | 7 +-
.../cloud/vision/example_vision_annotate_image.py | 7 +-
.../cloud/vision/example_vision_autogenerated.py | 7 +-
.../google/cloud/vision/example_vision_explicit.py | 7 +-
.../google/cloud/workflows/example_workflows.py | 7 +-
.../tests/system/google/leveldb/example_leveldb.py | 6 +-
.../marketing_platform/example_analytics_admin.py | 7 +-
.../marketing_platform/example_campaign_manager.py | 7 +-
.../marketing_platform/example_display_video.py | 7 +-
.../system/google/suite/example_local_to_drive.py | 7 +-
.../unit/google/cloud/operators/test_pubsub.py | 32 +
.../google/cloud/sensors/test_cloud_composer.py | 22 +
providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 11 +
providers/microsoft/azure/pyproject.toml | 6 +-
.../providers/microsoft/azure/hooks/msgraph.py | 196 ++--
.../providers/microsoft/azure/triggers/msgraph.py | 45 +-
.../providers/microsoft/azure/triggers/powerbi.py | 107 ++-
.../system/microsoft/azure/example_s3_to_wasb.py | 7 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 68 +-
.../unit/microsoft/azure/triggers/test_msgraph.py | 8 +-
providers/postgres/docs/connections/postgres.rst | 1 +
providers/postgres/pyproject.toml | 4 +
.../airflow/providers/postgres/hooks/postgres.py | 222 ++++-
.../tests/unit/postgres/hooks/test_postgres.py | 1001 ++++++++++++++------
.../tests/system/samba/example_gcs_to_samba.py | 7 +-
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 21 +-
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 3 +-
.../example_dags/example_bash_decorator.py | 7 +-
.../example_dags/example_branch_operator.py | 7 +-
.../example_branch_operator_decorator.py | 7 +-
.../standard/example_dags/example_sensors.py | 7 +-
.../example_short_circuit_decorator.py | 7 +-
.../example_dags/example_short_circuit_operator.py | 7 +-
.../src/airflow/providers/standard/exceptions.py | 2 +-
.../airflow/providers/standard/triggers/hitl.py | 4 +-
.../tests/unit/standard/decorators/test_python.py | 21 +-
.../unit/standard/decorators/test_short_circuit.py | 6 +-
.../operators/test_latest_only_operator.py | 7 +-
.../tests/unit/standard/operators/test_python.py | 6 +-
.../tests/unit/standard/triggers/test_hitl.py | 6 +-
.../system/yandex/example_yandexcloud_dataproc.py | 6 +-
.../example_yandexcloud_dataproc_lightweight.py | 6 +-
reproducible_build.yaml | 4 +-
scripts/ci/prek/supported_versions.py | 2 +-
task-sdk/docs/api.rst | 2 +
task-sdk/src/airflow/sdk/__init__.py | 3 +
task-sdk/src/airflow/sdk/__init__.pyi | 3 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 16 +
task-sdk/src/airflow/sdk/bases/decorator.py | 3 +-
task-sdk/src/airflow/sdk/bases/operator.py | 9 +-
.../sdk/definitions/_internal/abstractoperator.py | 3 +-
task-sdk/src/airflow/sdk/definitions/connection.py | 6 +
task-sdk/src/airflow/sdk/definitions/dag.py | 5 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 3 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 2 +-
task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 2 +-
task-sdk/src/airflow/sdk/exceptions.py | 20 +
task-sdk/src/airflow/sdk/execution_time/comms.py | 7 +-
task-sdk/src/airflow/sdk/execution_time/hitl.py | 2 +-
.../airflow/sdk/execution_time/secrets_masker.py | 8 +-
task-sdk/tests/conftest.py | 3 +-
.../tests/task_sdk/definitions/test_connections.py | 17 +
task-sdk/tests/task_sdk/definitions/test_dag.py | 193 ++++
.../task_sdk/definitions/test_mappedoperator.py | 3 +-
.../task_sdk/definitions/test_secrets_masker.py | 34 +-
.../tests/task_sdk/execution_time/test_hitl.py | 6 +-
369 files changed, 4759 insertions(+), 1490 deletions(-)
rename airflow-core/src/airflow/{utils => task}/trigger_rule.py (100%)
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/tr/admin.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/tr/assets.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/tr/browse.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/tr/common.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/tr/components.json
create mode 100644 airflow-core/src/airflow/ui/public/i18n/locales/tr/dag.json
create mode 100644 airflow-core/src/airflow/ui/public/i18n/locales/tr/dags.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/tr/dashboard.json
create mode 100644 airflow-core/src/airflow/ui/public/i18n/locales/tr/hitl.json
copy airflow-core/src/airflow/ui/src/{components/ui/NumberInput.tsx =>
pages/Events/filterUtils.ts} (50%)
delete mode 100644 airflow-core/tests/unit/utils/test_dag_cycle.py
