This is an automated email from the ASF dual-hosted git repository.
jedcunningham pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 3eea44e9a7 Chart: Add init containers for jobs (#40454)
add a62bd83188 Enable enforcing pydocstyle rule D213 in ruff. (#40448)
No new revisions were added by this update.
Summary of changes:
airflow/api/client/api_client.py | 15 +-
airflow/api/client/json_client.py | 27 ++-
airflow/api/common/experimental/get_code.py | 3 +-
.../api/common/experimental/get_dag_run_state.py | 3 +-
airflow/api/common/mark_tasks.py | 9 +-
airflow/api/common/trigger_dag.py | 6 +-
.../endpoints/dag_warning_endpoint.py | 3 +-
airflow/api_connexion/schemas/dag_run_schema.py | 3 +-
airflow/auth/managers/base_auth_manager.py | 3 +-
airflow/cli/cli_parser.py | 3 +-
airflow/cli/commands/connection_command.py | 3 +-
airflow/cli/commands/daemon_utils.py | 3 +-
airflow/cli/commands/provider_command.py | 3 +-
airflow/cli/commands/task_command.py | 6 +-
airflow/cli/utils.py | 3 +-
airflow/configuration.py | 6 +-
airflow/dag_processing/manager.py | 3 +-
airflow/datasets/__init__.py | 24 ++-
airflow/decorators/base.py | 9 +-
airflow/decorators/bash.py | 6 +-
airflow/decorators/task_group.py | 9 +-
airflow/executors/base_executor.py | 9 +-
airflow/executors/executor_loader.py | 12 +-
airflow/io/path.py | 12 +-
.../pre_7_4_0_compatibility/pod_generator.py | 6 +-
airflow/migrations/env.py | 6 +-
.../versions/0001_1_5_0_current_schema.py | 3 +-
.../versions/0002_1_5_0_create_is_encrypted.py | 3 +-
.../versions/0003_1_5_0_for_compatibility.py | 3 +-
.../0004_1_5_0_more_logging_into_task_isntance.py | 3 +-
.../versions/0005_1_5_2_job_id_indices.py | 3 +-
.../versions/0006_1_6_0_adding_extra_to_log.py | 3 +-
.../migrations/versions/0007_1_6_0_add_dagrun.py | 3 +-
.../versions/0008_1_6_0_task_duration.py | 3 +-
.../versions/0009_1_6_0_dagrun_config.py | 3 +-
.../0010_1_6_2_add_password_column_to_user.py | 3 +-
.../versions/0011_1_6_2_dagrun_start_end.py | 3 +-
...7_0_add_notification_sent_column_to_sla_miss.py | 3 +-
..._1_7_0_add_a_column_to_track_the_encryption_.py | 3 +-
...4_1_7_0_add_is_encrypted_column_to_variable_.py | 3 +-
.../versions/0015_1_7_1_rename_user_table.py | 3 +-
.../versions/0016_1_7_1_add_ti_state_index.py | 3 +-
.../0017_1_7_1_add_task_fails_journal_table.py | 3 +-
.../versions/0018_1_7_1_add_dag_stats_table.py | 3 +-
...1_7_1_add_fractional_seconds_to_mysql_tables.py | 3 +-
.../versions/0020_1_7_1_xcom_dag_task_indices.py | 3 +-
.../0021_1_7_1_add_pid_field_to_taskinstance.py | 3 +-
..._7_1_add_dag_id_state_index_on_dag_run_table.py | 3 +-
..._1_8_2_add_max_tries_column_to_task_instance.py | 3 +-
..._1_8_2_make_xcom_value_column_a_large_binary.py | 3 +-
.../versions/0025_1_8_2_add_ti_job_id_index.py | 3 +-
.../0026_1_8_2_increase_text_size_for_mysql.py | 3 +-
.../0027_1_10_0_add_time_zone_awareness.py | 3 +-
...1_10_0_add_kubernetes_resource_checkpointing.py | 3 +-
..._1_10_0_add_executor_config_to_task_instance.py | 3 +-
...0_1_10_0_add_kubernetes_scheduler_uniqueness.py | 3 +-
.../migrations/versions/0031_1_10_0_merge_heads.py | 3 +-
.../0032_1_10_0_fix_mysql_not_null_constraint.py | 3 +-
.../versions/0033_1_10_0_fix_sqlite_foreign_key.py | 3 +-
.../versions/0034_1_10_0_index_taskfail.py | 3 +-
.../versions/0035_1_10_2_add_idx_log_dag.py | 3 +-
.../0036_1_10_2_add_index_to_taskinstance.py | 3 +-
.../0037_1_10_2_add_task_reschedule_table.py | 3 +-
.../versions/0038_1_10_2_add_sm_dag_index.py | 3 +-
.../versions/0039_1_10_2_add_superuser_field.py | 3 +-
.../versions/0040_1_10_3_add_fields_to_dag.py | 3 +-
.../0041_1_10_3_add_schedule_interval_to_dag.py | 3 +-
..._1_10_3_task_reschedule_fk_on_cascade_delete.py | 3 +-
...3_1_10_4_make_taskinstance_pool_not_nullable.py | 3 +-
.../0044_1_10_7_add_serialized_dag_table.py | 3 +-
.../versions/0045_1_10_7_add_root_dag_id_to_dag.py | 3 +-
...0_5_change_datetime_to_datetime2_6_on_mssql_.py | 18 +-
.../0047_1_10_4_increase_queue_name_size_limit.py | 3 +-
.../versions/0048_1_10_3_remove_dag_stat_table.py | 3 +-
.../migrations/versions/0049_1_10_7_merge_heads.py | 3 +-
...10_7_increase_length_for_connection_password.py | 3 +-
.../versions/0051_1_10_8_add_dagtags_table.py | 3 +-
..._10_10_add_pool_slots_field_to_task_instance.py | 3 +-
...0_10_add_rendered_task_instance_fields_table.py | 3 +-
.../versions/0054_1_10_10_add_dag_code_table.py | 3 +-
..._11_add_precision_to_execution_date_in_mysql.py | 3 +-
...10_12_add_dag_hash_column_to_serialized_dag_.py | 3 +-
.../versions/0057_1_10_13_add_fab_tables.py | 3 +-
...1_10_13_increase_length_of_fab_ab_view_menu_.py | 3 +-
.../versions/0059_2_0_0_drop_user_and_chart.py | 3 +-
.../0060_2_0_0_remove_id_column_from_xcom.py | 3 +-
.../0061_2_0_0_increase_length_of_pool_name.py | 3 +-
.../0063_2_0_0_set_conn_type_as_non_nullable.py | 3 +-
.../0064_2_0_0_add_unique_constraint_to_conn_id.py | 3 +-
.../0065_2_0_0_update_schema_for_smart_sensor.py | 3 +-
.../0066_2_0_0_add_queued_by_job_id_to_ti.py | 3 +-
.../0067_2_0_0_add_external_executor_id_to_ti.py | 3 +-
.../0068_2_0_0_drop_kuberesourceversion_and_.py | 3 +-
...2_0_0_add_scheduling_decision_to_dagrun_and_.py | 3 +-
...0_fix_mssql_exec_date_rendered_task_instance.py | 3 +-
.../0071_2_0_0_add_job_id_to_dagrun_table.py | 3 +-
...072_2_0_0_add_k8s_yaml_to_rendered_templates.py | 3 +-
.../versions/0073_2_0_0_prefix_dag_permissions.py | 3 +-
.../0074_2_0_0_resource_based_permissions.py | 3 +-
...75_2_0_0_add_description_field_to_connection.py | 3 +-
..._0_0_fix_description_field_in_connection_to_.py | 3 +-
...2_0_0_change_field_in_dagcode_to_mediumtext_.py | 3 +-
..._2_0_1_remove_can_read_permission_on_config_.py | 3 +-
...0_2_increase_size_of_connection_extra_field_.py | 3 +-
.../0080_2_0_2_change_default_pool_slots_to_1.py | 3 +-
.../0081_2_0_2_rename_last_scheduler_run_column.py | 3 +-
..._1_0_increase_pool_name_size_in_taskinstance.py | 3 +-
...0083_2_1_0_add_description_field_to_variable.py | 3 +-
..._1_0_resource_based_permissions_for_default_.py | 3 +-
...5_2_1_3_add_queued_at_column_to_dagrun_table.py | 3 +-
..._1_4_add_max_active_runs_column_to_dagmodel_.py | 3 +-
..._2_1_4_add_index_on_state_dag_id_for_queued_.py | 3 +-
.../0088_2_2_0_improve_mssql_compatibility.py | 3 +-
...89_2_2_0_make_xcom_pkey_columns_non_nullable.py | 3 +-
..._2_0_rename_concurrency_column_in_dag_table_.py | 3 +-
.../0091_2_2_0_add_trigger_table_and_task_info.py | 3 +-
...ta_interval_start_end_to_dagmodel_and_dagrun.py | 3 +-
.../0093_2_2_0_taskinstance_keyed_to_dagrun.py | 3 +-
...2_3_add_has_import_errors_column_to_dagmodel.py | 3 +-
.../versions/0095_2_2_4_add_session_table_to_db.py | 3 +-
.../0096_2_2_4_adding_index_for_dag_id_in_job.py | 3 +-
..._2_3_0_increase_length_of_email_and_username.py | 3 +-
...098_2_3_0_added_timetable_description_column.py | 3 +-
...9_2_3_0_add_task_log_filename_template_model.py | 3 +-
...2_3_0_add_taskmap_and_map_id_on_taskinstance.py | 3 +-
..._2_3_0_add_data_compressed_to_serialized_dag.py | 3 +-
.../0102_2_3_0_switch_xcom_table_to_use_run_id.py | 9 +-
.../0103_2_3_0_add_callback_request_table.py | 3 +-
...3_0_migrate_rtif_to_use_run_id_and_map_index.py | 3 +-
.../0105_2_3_0_add_map_index_to_taskfail.py | 3 +-
...on_for_fab_tables_to_add_missing_constraints.py | 3 +-
.../versions/0107_2_3_0_add_map_index_to_log.py | 3 +-
.../versions/0108_2_3_0_default_dag_view_grid.py | 3 +-
.../0109_2_3_1_add_index_for_event_in_log.py | 3 +-
...0110_2_3_2_add_cascade_to_dag_tag_foreignkey.py | 3 +-
.../0111_2_3_3_add_indexes_for_cascade_deletes.py | 3 +-
.../versions/0112_2_4_0_add_dagwarning_model.py | 3 +-
.../0113_2_4_0_compare_types_between_orm_and_db.py | 3 +-
.../versions/0114_2_4_0_add_dataset_model.py | 3 +-
.../versions/0115_2_4_0_remove_smart_sensors.py | 3 +-
.../0116_2_4_0_add_dag_owner_attributes_table.py | 3 +-
..._2_4_0_add_processor_subdir_to_dagmodel_and_.py | 3 +-
.../versions/0118_2_4_2_add_missing_autoinc_fab.py | 6 +-
...e_insensitive_unique_constraint_for_username.py | 3 +-
.../0120_2_5_0_add_updated_at_to_dagrun_and_ti.py | 3 +-
...21_2_5_0_add_dagrunnote_and_taskinstancenote.py | 3 +-
.../0122_2_5_0_add_is_orphaned_to_datasetmodel.py | 3 +-
.../0123_2_6_0_add_dttm_index_on_log_table.py | 3 +-
...0_increase_length_of_user_identifier_columns.py | 3 +-
.../0125_2_6_2_add_onupdate_cascade_to_taskmap.py | 3 +-
.../0126_2_7_0_add_index_to_task_instance_table.py | 3 +-
.../0127_2_7_0_add_custom_operator_name_column.py | 3 +-
...28_2_7_0_add_include_deferred_column_to_pool.py | 3 +-
.../0129_2_8_0_add_clear_number_to_dag_run.py | 3 +-
..._0_add_owner_display_name_to_audit_log_table.py | 3 +-
...31_2_8_0_make_connection_login_password_text.py | 3 +-
...0132_2_8_0_add_processor_subdir_import_error.py | 3 +-
.../0133_2_8_1_refactor_dag_run_indexes.py | 3 +-
...2_9_0_add_rendered_map_index_to_taskinstance.py | 3 +-
...audit_log_table_and_change_event_name_length.py | 3 +-
...136_2_9_0_add_dataset_expression_in_dagmodel.py | 3 +-
...2_9_0_adding_adding_max_failure_runs_column_.py | 3 +-
..._2_9_0_make_xcom_value_to_longblob_for_mysql.py | 3 +-
...139_2_9_0_add_display_name_for_dag_and_task_.py | 3 +-
.../0140_2_9_0_update_trigger_kwargs_type.py | 3 +-
...1_2_9_2_remove_idx_last_scheduling_decision_.py | 3 +-
...nconsistency_between_ORM_and_migration_files.py | 3 +-
...dexes_on_dag_id_column_in_referencing_tables.py | 3 +-
.../0144_2_10_0_add_new_executor_field_to_db.py | 3 +-
...2_10_0_added_dagpriorityparsingrequest_table.py | 3 +-
.../0146_2_10_0_add_task_instance_history.py | 3 +-
airflow/models/abstractoperator.py | 33 ++-
airflow/models/baseoperator.py | 21 +-
airflow/models/baseoperatorlink.py | 3 +-
airflow/models/connection.py | 3 +-
airflow/models/dag.py | 42 ++--
airflow/models/dagbag.py | 3 +-
airflow/models/dagcode.py | 24 ++-
airflow/models/dagrun.py | 15 +-
airflow/models/expandinput.py | 15 +-
airflow/models/mappedoperator.py | 15 +-
airflow/models/param.py | 3 +-
airflow/models/renderedtifields.py | 3 +-
airflow/models/serialized_dag.py | 12 +-
airflow/models/taskinstance.py | 24 ++-
airflow/models/taskinstancekey.py | 3 +-
airflow/models/tasklog.py | 3 +-
airflow/models/taskmap.py | 6 +-
airflow/models/taskmixin.py | 3 +-
airflow/models/trigger.py | 6 +-
airflow/models/variable.py | 15 +-
airflow/models/xcom.py | 48 +++--
airflow/models/xcom_arg.py | 30 ++-
airflow/notifications/basenotifier.py | 3 +-
airflow/operators/bash.py | 3 +-
airflow/operators/datetime.py | 3 +-
airflow/operators/python.py | 6 +-
airflow/operators/subdag.py | 3 +-
airflow/operators/weekday.py | 3 +-
airflow/policies.py | 3 +-
airflow/providers/amazon/aws/hooks/athena.py | 27 ++-
airflow/providers/amazon/aws/hooks/athena_sql.py | 3 +-
airflow/providers/amazon/aws/hooks/base_aws.py | 27 ++-
airflow/providers/amazon/aws/hooks/chime.py | 3 +-
airflow/providers/amazon/aws/hooks/datasync.py | 9 +-
airflow/providers/amazon/aws/hooks/ecr.py | 3 +-
airflow/providers/amazon/aws/hooks/ecs.py | 18 +-
airflow/providers/amazon/aws/hooks/glacier.py | 12 +-
airflow/providers/amazon/aws/hooks/kinesis.py | 3 +-
airflow/providers/amazon/aws/hooks/logs.py | 6 +-
.../providers/amazon/aws/hooks/redshift_cluster.py | 36 ++--
.../providers/amazon/aws/hooks/redshift_data.py | 6 +-
airflow/providers/amazon/aws/hooks/redshift_sql.py | 9 +-
airflow/providers/amazon/aws/hooks/sagemaker.py | 123 +++++++----
.../providers/amazon/aws/hooks/secrets_manager.py | 9 +-
airflow/providers/amazon/aws/hooks/sts.py | 3 +-
airflow/providers/amazon/aws/operators/athena.py | 3 +-
airflow/providers/amazon/aws/operators/batch.py | 18 +-
airflow/providers/amazon/aws/operators/datasync.py | 3 +-
airflow/providers/amazon/aws/operators/glue.py | 6 +-
airflow/providers/amazon/aws/operators/neptune.py | 3 +-
.../amazon/aws/operators/redshift_cluster.py | 3 +-
.../providers/amazon/aws/operators/sagemaker.py | 3 +-
airflow/providers/amazon/aws/sensors/base_aws.py | 3 +-
.../providers/amazon/aws/transfers/mongo_to_s3.py | 9 +-
.../amazon/aws/transfers/s3_to_dynamodb.py | 3 +-
.../providers/amazon/aws/transfers/s3_to_sql.py | 3 +-
.../amazon/aws/utils/connection_wrapper.py | 15 +-
airflow/providers/amazon/aws/utils/mixins.py | 3 +-
airflow/providers/amazon/aws/utils/redshift.py | 3 +-
.../apache/druid/transfers/hive_to_druid.py | 3 +-
airflow/providers/apache/hdfs/hooks/webhdfs.py | 3 +-
airflow/providers/apache/hive/hooks/hive.py | 6 +-
.../providers/apache/hive/operators/hive_stats.py | 3 +-
.../apache/hive/transfers/vertica_to_hive.py | 3 +-
airflow/providers/apache/kafka/hooks/client.py | 3 +-
.../providers/apache/kafka/operators/consume.py | 3 +-
.../providers/apache/kafka/operators/produce.py | 3 +-
airflow/providers/apache/kafka/sensors/kafka.py | 3 +-
.../apache/kafka/triggers/await_message.py | 3 +-
.../providers/apache/kylin/operators/kylin_cube.py | 3 +-
airflow/providers/apache/livy/triggers/livy.py | 3 +-
airflow/providers/apache/pig/hooks/pig.py | 3 +-
.../providers/apache/spark/hooks/spark_submit.py | 6 +-
airflow/providers/atlassian/jira/operators/jira.py | 3 +-
.../providers/celery/executors/celery_executor.py | 3 +-
airflow/providers/cncf/kubernetes/callbacks.py | 24 ++-
.../cncf/kubernetes/decorators/kubernetes.py | 3 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 30 ++-
.../cncf/kubernetes/kubernetes_helper_functions.py | 9 +-
airflow/providers/cohere/operators/embedding.py | 3 +-
airflow/providers/common/io/xcom/backend.py | 15 +-
airflow/providers/common/sql/hooks/sql.py | 12 +-
airflow/providers/common/sql/operators/sql.py | 3 +-
airflow/providers/common/sql/sensors/sql.py | 3 +-
airflow/providers/databricks/hooks/databricks.py | 9 +-
.../providers/databricks/hooks/databricks_sql.py | 3 +-
.../providers/databricks/operators/databricks.py | 3 +-
airflow/providers/dbt/cloud/sensors/dbt.py | 6 +-
airflow/providers/dbt/cloud/triggers/dbt.py | 3 +-
airflow/providers/dingding/hooks/dingding.py | 6 +-
airflow/providers/docker/operators/docker.py | 12 +-
airflow/providers/docker/operators/docker_swarm.py | 3 +-
.../providers/elasticsearch/log/es_task_handler.py | 3 +-
airflow/providers/exasol/hooks/exasol.py | 27 ++-
.../fab/auth_manager/security_manager/override.py | 15 +-
airflow/providers/facebook/ads/hooks/ads.py | 12 +-
airflow/providers/github/operators/github.py | 3 +-
airflow/providers/google/ads/hooks/ads.py | 24 ++-
.../providers/google/ads/transfers/ads_to_gcs.py | 3 +-
.../_internal_client/secret_manager_client.py | 9 +-
airflow/providers/google/cloud/hooks/bigquery.py | 237 ++++++++++++++-------
airflow/providers/google/cloud/hooks/cloud_sql.py | 18 +-
.../cloud/hooks/cloud_storage_transfer_service.py | 51 +++--
airflow/providers/google/cloud/hooks/dataflow.py | 6 +-
airflow/providers/google/cloud/hooks/dataform.py | 3 +-
airflow/providers/google/cloud/hooks/datafusion.py | 6 +-
airflow/providers/google/cloud/hooks/dataproc.py | 153 ++++++++-----
airflow/providers/google/cloud/hooks/functions.py | 30 ++-
.../google/cloud/hooks/kubernetes_engine.py | 33 ++-
airflow/providers/google/cloud/hooks/os_login.py | 3 +-
.../providers/google/cloud/hooks/secret_manager.py | 27 ++-
airflow/providers/google/cloud/hooks/translate.py | 3 +-
.../cloud/hooks/vertex_ai/batch_prediction_job.py | 3 +-
.../google/cloud/hooks/vertex_ai/pipeline_job.py | 3 +-
airflow/providers/google/cloud/links/base.py | 3 +-
airflow/providers/google/cloud/links/datafusion.py | 3 +-
.../google/cloud/log/stackdriver_task_handler.py | 6 +-
.../providers/google/cloud/openlineage/utils.py | 6 +-
.../providers/google/cloud/operators/bigquery.py | 63 ++++--
.../providers/google/cloud/operators/cloud_sql.py | 33 ++-
.../providers/google/cloud/operators/dataform.py | 3 +-
.../providers/google/cloud/operators/dataproc.py | 102 ++++++---
.../google/cloud/operators/dataproc_metastore.py | 36 ++--
airflow/providers/google/cloud/operators/gcs.py | 3 +-
airflow/providers/google/cloud/operators/pubsub.py | 15 +-
.../google/cloud/operators/vertex_ai/custom_job.py | 9 +-
.../cloud/operators/vertex_ai/pipeline_job.py | 3 +-
airflow/providers/google/cloud/operators/vision.py | 54 +++--
airflow/providers/google/cloud/sensors/gcs.py | 3 +-
airflow/providers/google/cloud/sensors/pubsub.py | 3 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 3 +-
.../google/cloud/transfers/facebook_ads_to_gcs.py | 3 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 3 +-
.../google/cloud/transfers/mysql_to_gcs.py | 3 +-
.../google/cloud/transfers/oracle_to_gcs.py | 3 +-
.../google/cloud/transfers/presto_to_gcs.py | 3 +-
.../providers/google/cloud/transfers/s3_to_gcs.py | 3 +-
.../google/cloud/transfers/trino_to_gcs.py | 3 +-
.../providers/google/cloud/triggers/cloud_batch.py | 3 +-
.../providers/google/cloud/triggers/cloud_run.py | 3 +-
.../providers/google/cloud/triggers/dataflow.py | 3 +-
.../providers/google/cloud/triggers/vertex_ai.py | 3 +-
.../google/cloud/utils/external_token_supplier.py | 6 +-
.../google/cloud/utils/field_sanitizer.py | 6 +-
.../google/cloud/utils/field_validator.py | 9 +-
airflow/providers/google/cloud/utils/helpers.py | 3 +-
.../providers/google/common/hooks/base_google.py | 3 +-
.../google/common/utils/id_token_credentials.py | 3 +-
airflow/providers/google/go_module_utils.py | 6 +-
.../marketing_platform/hooks/analytics_admin.py | 18 +-
.../marketing_platform/links/analytics_admin.py | 3 +-
.../google/suite/transfers/local_to_drive.py | 3 +-
airflow/providers/http/hooks/http.py | 27 ++-
airflow/providers/http/operators/http.py | 6 +-
airflow/providers/influxdb/hooks/influxdb.py | 12 +-
airflow/providers/jdbc/hooks/jdbc.py | 9 +-
.../jenkins/operators/jenkins_job_trigger.py | 12 +-
airflow/providers/jenkins/sensors/jenkins.py | 3 +-
airflow/providers/microsoft/azure/hooks/asb.py | 15 +-
.../microsoft/azure/hooks/data_factory.py | 3 +-
.../providers/microsoft/azure/hooks/data_lake.py | 54 +++--
airflow/providers/microsoft/azure/operators/asb.py | 30 ++-
.../providers/microsoft/azure/operators/cosmos.py | 3 +-
.../microsoft/azure/sensors/data_factory.py | 3 +-
airflow/providers/microsoft/azure/sensors/wasb.py | 6 +-
.../microsoft/azure/triggers/data_factory.py | 6 +-
airflow/providers/microsoft/azure/utils.py | 12 +-
airflow/providers/microsoft/psrp/operators/psrp.py | 3 +-
airflow/providers/odbc/hooks/odbc.py | 6 +-
airflow/providers/openlineage/extractors/base.py | 9 +-
airflow/providers/openlineage/plugins/adapter.py | 3 +-
airflow/providers/openlineage/plugins/facets.py | 3 +-
airflow/providers/openlineage/sqlparser.py | 6 +-
.../openlineage/utils/selective_enable.py | 9 +-
airflow/providers/openlineage/utils/sql.py | 6 +-
airflow/providers/oracle/hooks/oracle.py | 9 +-
airflow/providers/postgres/hooks/postgres.py | 21 +-
airflow/providers/samba/hooks/samba.py | 3 +-
airflow/providers/sftp/hooks/sftp.py | 54 +++--
airflow/providers/slack/hooks/slack.py | 3 +-
airflow/providers/slack/operators/slack.py | 12 +-
airflow/providers/slack/utils/__init__.py | 9 +-
airflow/providers/smtp/hooks/smtp.py | 3 +-
airflow/providers/snowflake/hooks/snowflake.py | 12 +-
.../snowflake/transfers/copy_into_snowflake.py | 3 +-
airflow/providers/snowflake/utils/openlineage.py | 3 +-
airflow/providers/ssh/hooks/ssh.py | 12 +-
airflow/providers/tableau/hooks/tableau.py | 6 +-
airflow/providers/teradata/hooks/teradata.py | 9 +-
airflow/providers/weaviate/hooks/weaviate.py | 45 ++--
airflow/providers/yandex/hooks/yq.py | 18 +-
airflow/providers/yandex/operators/dataproc.py | 21 +-
airflow/security/permissions.py | 3 +-
airflow/security/utils.py | 3 +-
airflow/serialization/helpers.py | 3 +-
airflow/serialization/serde.py | 12 +-
airflow/serialization/serialized_objects.py | 9 +-
airflow/serialization/serializers/timezone.py | 3 +-
airflow/settings.py | 3 +-
airflow/task/priority_strategy.py | 12 +-
airflow/template/templater.py | 3 +-
airflow/ti_deps/deps/base_ti_dep.py | 3 +-
airflow/ti_deps/deps/prev_dagrun_dep.py | 12 +-
airflow/ti_deps/deps/trigger_rule_dep.py | 21 +-
airflow/timetables/_cron.py | 12 +-
airflow/timetables/base.py | 33 ++-
airflow/timetables/interval.py | 24 ++-
airflow/timetables/simple.py | 15 +-
airflow/timetables/trigger.py | 3 +-
airflow/utils/cli_action_loggers.py | 12 +-
airflow/utils/context.py | 30 ++-
airflow/utils/dag_cycle_tester.py | 3 +-
airflow/utils/dates.py | 12 +-
airflow/utils/db.py | 24 ++-
airflow/utils/email.py | 3 +-
airflow/utils/entry_points.py | 3 +-
airflow/utils/file.py | 9 +-
airflow/utils/helpers.py | 6 +-
airflow/utils/json.py | 3 +-
airflow/utils/log/file_task_handler.py | 3 +-
airflow/utils/log/logging_mixin.py | 6 +-
airflow/utils/log/secrets_masker.py | 12 +-
airflow/utils/log/timezone_aware.py | 6 +-
airflow/utils/mixins.py | 6 +-
airflow/utils/operator_helpers.py | 6 +-
airflow/utils/process_utils.py | 3 +-
airflow/utils/setup_teardown.py | 3 +-
airflow/utils/sqlalchemy.py | 6 +-
airflow/utils/state.py | 6 +-
airflow/utils/task_group.py | 9 +-
airflow/utils/timezone.py | 12 +-
airflow/utils/types.py | 3 +-
airflow/utils/yaml.py | 3 +-
airflow/www/extensions/init_appbuilder.py | 18 +-
airflow/www/extensions/init_manifest_files.py | 6 +-
airflow/www/extensions/init_views.py | 9 +-
airflow/www/forms.py | 9 +-
airflow/www/security.py | 3 +-
airflow/www/security_appless.py | 3 +-
airflow/www/security_manager.py | 6 +-
airflow/www/utils.py | 9 +-
airflow/www/validators.py | 9 +-
airflow/www/views.py | 18 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
pyproject.toml | 4 +-
416 files changed, 2429 insertions(+), 1216 deletions(-)
