You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2020/12/09 10:16:21 UTC
[airflow] tag nightly-master updated (3663d15 -> 18a7a35)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/airflow.git.
*** WARNING: tag nightly-master was modified! ***
from 3663d15 (commit)
to 18a7a35 (commit)
from 3663d15 Fix links to moved production-deployment file (#12854)
add a878959 Remove old option - git_password from sensitive_config_values (#12821)
add a70cace Don't show "Access deined" message on login page (#12846)
add 7cfd240 Add start_date and end_date to DagRun View in UI (#12871)
add 5d328a2 Show DAG serialization errors in the UI. (#12866)
add 4d44faa Adds airflow as viable docker command in official image (#12878)
add 818195f Remove first_task_scheduling_delay from Updating.md (#12885)
add 1dcef78 Clarifies version args for installing 1.10 in Docker (#12875)
add 2c70ac4 Update commands to verify singature and shasum for Providers (#12886)
add eed6576 Adjust inner/nested radius to remove unwanted visual gap (#12887)
add 4fb3121 Refactor `@provide_session` to do less "at runtime" (#12868)
add 01707d7 Improve support for special characters in DbApiHook.get_uri (#12775)
add 312a281 Bugfix: Entrypoint Import Exception masked by attribute error (#12862)
add c2411e3 Make Migrations 1.10.14 Compatible (#12896)
add 190066c Kubernetes worker pod doesn't use docker container entrypoint (#12766)
add b115512 Use consistent style for detecting current DB type in migrations (#12898)
add f66a46d Changes the type of source_code field in DagCode to MEDIUMTEXT (#12890)
add 29d7848 Fix plugin macros not being exposed through airflow.macros (#12788)
add d8906ab Minor changes in description of API docs (#12532)
add 23e743e Move task handlers guides to provider docs (#12826)
add 7d37391 Fix Multiple Migrations Heads (#12901)
add 5f65cec Add docs for new scheduler "clean-up" tunables. (#12899)
add cb70150 Fix broken MySQL Migration (#12904)
add 5e0a2d7 Fix failing test in TestSchedulerJob (#12906)
add ef523b4 Move branch_operator.py to branch.py (#12900)
add f9e9ad2 Builds prod images on DockerHub from packages (#12908)
add 85dd092 Make sure perms list isn't None before looking within list (#12915)
add ff25bd6 Make xcom_pull results order deterministic (#12905)
add 4d24c5e Update comments in setup.py (#12903)
add 9b39f24 Add support for dynamic connection form fields per provider (#12558)
add e7c1771 Adds predefined providers to install_requires. (#12916)
add bc4d9d0 Remove duplicate entry in Updating.md (#12919)
add 7c028f5 ImportErrors are collapsed by default (#12811)
add 0da5232 Added documentation for Airflow Upgrade Check (#12872)
add bfbd4bb Moved subdag_operator.py to subdag.py (#11307)
add 738c953 Add missing licences. (#12922)
add ed6eb42 Use "auto" instead of "scroll" to prevent visible (unused) scrollbars in some browsers (#12923)
add b40dffa Rename remaing modules to match AIP-21 (#12917)
add 4939816 Increase timeout for SQLite tests to 80 minutes (#12926)
add c704293 Warning about unsafe migrations (#10254)
add d558967 Move dummy_operator.py to dummy.py (#11178) (#11293)
add abce78c Disable experimental REST API by default (#12337)
add 3da939b Update doc to reflect the changes for DAG-Level access control (#12928)
add 73843d0 Disable Pause/Unpause switch if user doesn't have edit access for DAG. (#12911)
add e595d35 Simplify publishing of documentation (#12892)
add a075b6d Rename remaining Sensors to match AIP-21 (#12927)
add bfbe486 Fix typo in metrics doc (#12934)
add 3835062 Add Clarification to pod_template_file exmaples (#12932)
add 63ea88d Apply labels to Docker images in a single instruction (#12931)
add 53c4847 shorten name of hook re imports of provide_session and create_session (#12936)
add d7ddf16 Fixed failed pylint in master (#12938)
add 8d6840b Fix typo in setup.cfg (#12935)
add 5c74c3a Add explanation of the Presto Kerberos + SSL + snowflake problem (#12939)
add 18a7a35 Enhanced TaskFlow API tutorial to use @dag decorator (#12937)
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 2 +-
.pre-commit-config.yaml | 8 +-
.rat-excludes | 6 +-
Dockerfile | 47 +--
Dockerfile.ci | 18 +-
IMAGES.rst | 2 +
UPDATING.md | 58 ++--
UPGRADING_TO_2.0.md | 24 +-
airflow/__init__.py | 5 +
airflow/api/common/experimental/mark_tasks.py | 2 +-
airflow/api_connexion/openapi/v1.yaml | 29 +-
airflow/cli/cli_parser.py | 24 +-
airflow/cli/commands/connection_command.py | 2 +-
airflow/cli/commands/info_command.py | 6 +-
airflow/cli/commands/kubernetes_command.py | 2 +-
airflow/cli/commands/provider_command.py | 42 ++-
airflow/config_templates/config.yml | 27 +-
airflow/config_templates/default_airflow.cfg | 19 +-
airflow/configuration.py | 1 -
airflow/contrib/sensors/weekday_sensor.py | 2 +-
.../customized_form_field_behaviours.schema.json | 32 +++
airflow/example_dags/example_bash_operator.py | 2 +-
airflow/example_dags/example_branch_operator.py | 2 +-
.../example_branch_python_dop_operator_3.py | 2 +-
.../example_external_task_marker_dag.py | 4 +-
airflow/example_dags/example_latest_only.py | 2 +-
.../example_latest_only_with_trigger.py | 2 +-
airflow/example_dags/example_nested_branch_dag.py | 2 +-
.../example_dags/example_short_circuit_operator.py | 2 +-
airflow/example_dags/example_skip_dag.py | 2 +-
airflow/example_dags/example_subdag_operator.py | 4 +-
airflow/example_dags/example_task_group.py | 2 +-
airflow/example_dags/subdags/subdag.py | 2 +-
airflow/example_dags/tutorial_taskflow_api_etl.py | 57 ++--
airflow/exceptions.py | 4 +
airflow/executors/celery_executor.py | 2 +-
airflow/executors/kubernetes_executor.py | 2 +-
airflow/hooks/base.py | 172 +++++++++++
airflow/hooks/base_hook.py | 77 +----
airflow/hooks/{dbapi_hook.py => dbapi.py} | 5 +-
airflow/hooks/dbapi_hook.py | 317 +--------------------
airflow/hooks/filesystem.py | 2 +-
airflow/jobs/scheduler_job.py | 2 +-
airflow/kubernetes/pod_generator.py | 4 +-
.../dags_in_image_template.yaml | 3 +
.../dags_in_volume_template.yaml | 3 +
.../git_sync_template.yaml | 5 +-
airflow/lineage/__init__.py | 3 +-
...236f1_add_fractional_seconds_to_mysql_tables.py | 8 +-
.../versions/cf5dc11e79ad_drop_user_and_chart.py | 4 +-
.../d2ae31099d61_increase_text_size_for_mysql.py | 8 +-
...c3a5a_add_dag_hash_column_to_serialized_dag_.py | 4 +-
.../e38be357a868_update_schema_for_smart_sensor.py | 4 +-
...c86c_change_field_in_dagcode_to_mediumtext_.py} | 29 +-
airflow/models/connection.py | 12 +-
airflow/models/dag.py | 6 +-
airflow/models/dagbag.py | 31 +-
airflow/models/dagcode.py | 4 +-
airflow/models/taskinstance.py | 15 +-
.../operators/{branch_operator.py => branch.py} | 0
airflow/operators/branch_operator.py | 39 +--
airflow/operators/{dummy_operator.py => dummy.py} | 0
airflow/operators/dummy_operator.py | 26 +-
airflow/operators/generic_transfer.py | 2 +-
airflow/operators/latest_only.py | 2 +-
airflow/operators/python.py | 3 +-
airflow/operators/sql.py | 2 +-
.../operators/{subdag_operator.py => subdag.py} | 7 +-
airflow/operators/subdag_operator.py | 203 +------------
airflow/plugins_manager.py | 13 +-
.../example_google_api_to_s3_transfer_advanced.py | 2 +-
airflow/providers/amazon/aws/hooks/base_aws.py | 9 +-
airflow/providers/amazon/aws/hooks/emr.py | 7 +-
airflow/providers/amazon/aws/hooks/s3.py | 3 +
airflow/providers/amazon/aws/sensors/athena.py | 2 +-
.../amazon/aws/sensors/cloud_formation.py | 2 +-
.../amazon/aws/sensors/ec2_instance_state.py | 2 +-
airflow/providers/amazon/aws/sensors/emr_base.py | 2 +-
airflow/providers/amazon/aws/sensors/glacier.py | 2 +-
airflow/providers/amazon/aws/sensors/glue.py | 2 +-
.../amazon/aws/sensors/glue_catalog_partition.py | 2 +-
airflow/providers/amazon/aws/sensors/redshift.py | 2 +-
airflow/providers/amazon/aws/sensors/s3_key.py | 2 +-
.../amazon/aws/sensors/s3_keys_unchanged.py | 2 +-
airflow/providers/amazon/aws/sensors/s3_prefix.py | 2 +-
.../providers/amazon/aws/sensors/sagemaker_base.py | 2 +-
airflow/providers/amazon/aws/sensors/sqs.py | 2 +-
.../amazon/aws/sensors/step_function_execution.py | 2 +-
airflow/providers/amazon/provider.yaml | 5 +
.../providers/apache/cassandra/hooks/cassandra.py | 3 +-
.../providers/apache/cassandra/sensors/record.py | 2 +-
.../providers/apache/cassandra/sensors/table.py | 2 +-
airflow/providers/apache/druid/hooks/druid.py | 4 +-
airflow/providers/apache/hdfs/hooks/hdfs.py | 7 +-
airflow/providers/apache/hdfs/hooks/webhdfs.py | 2 +-
airflow/providers/apache/hdfs/provider.yaml | 3 +
airflow/providers/apache/hdfs/sensors/hdfs.py | 2 +-
airflow/providers/apache/hdfs/sensors/web_hdfs.py | 2 +-
airflow/providers/apache/hive/hooks/hive.py | 13 +-
airflow/providers/apache/hive/provider.yaml | 1 +
.../apache/hive/sensors/hive_partition.py | 2 +-
.../apache/hive/sensors/metastore_partition.py | 2 +-
.../apache/hive/sensors/named_hive_partition.py | 2 +-
airflow/providers/apache/kylin/hooks/kylin.py | 2 +-
airflow/providers/apache/livy/hooks/livy.py | 7 +-
airflow/providers/apache/livy/provider.yaml | 3 +
airflow/providers/apache/livy/sensors/livy.py | 2 +-
airflow/providers/apache/pig/hooks/pig.py | 3 +-
airflow/providers/apache/pinot/hooks/pinot.py | 4 +-
airflow/providers/apache/spark/hooks/spark_jdbc.py | 7 +-
airflow/providers/apache/spark/hooks/spark_sql.py | 9 +-
.../providers/apache/spark/hooks/spark_submit.py | 15 +-
airflow/providers/apache/spark/provider.yaml | 5 +
airflow/providers/apache/sqoop/hooks/sqoop.py | 9 +-
airflow/providers/apache/sqoop/provider.yaml | 3 +
airflow/providers/celery/sensors/celery_queue.py | 2 +-
airflow/providers/cloudant/hooks/cloudant.py | 13 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 33 ++-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 2 +-
airflow/providers/databricks/hooks/databricks.py | 9 +-
airflow/providers/databricks/provider.yaml | 3 +
airflow/providers/datadog/hooks/datadog.py | 2 +-
airflow/providers/datadog/sensors/datadog.py | 2 +-
airflow/providers/docker/hooks/docker.py | 26 +-
.../providers/elasticsearch/hooks/elasticsearch.py | 3 +-
airflow/providers/exasol/hooks/exasol.py | 3 +-
airflow/providers/facebook/ads/hooks/ads.py | 9 +-
airflow/providers/facebook/provider.yaml | 3 +
airflow/providers/ftp/hooks/ftp.py | 9 +-
airflow/providers/ftp/provider.yaml | 3 +
airflow/providers/ftp/sensors/ftp.py | 2 +-
airflow/providers/google/ads/hooks/ads.py | 2 +-
airflow/providers/google/cloud/hooks/bigquery.py | 5 +-
airflow/providers/google/cloud/hooks/cloud_sql.py | 15 +-
.../providers/google/cloud/hooks/compute_ssh.py | 10 +-
airflow/providers/google/cloud/hooks/dataprep.py | 3 +-
.../providers/google/cloud/operators/cloud_sql.py | 2 +-
airflow/providers/google/cloud/sensors/bigquery.py | 2 +-
.../providers/google/cloud/sensors/bigquery_dts.py | 2 +-
airflow/providers/google/cloud/sensors/bigtable.py | 2 +-
.../sensors/cloud_storage_transfer_service.py | 2 +-
airflow/providers/google/cloud/sensors/dataflow.py | 2 +-
airflow/providers/google/cloud/sensors/dataproc.py | 2 +-
airflow/providers/google/cloud/sensors/gcs.py | 2 +-
airflow/providers/google/cloud/sensors/pubsub.py | 2 +-
.../google/cloud/transfers/gcs_to_local.py | 2 +-
.../providers/google/common/hooks/base_google.py | 44 ++-
.../marketing_platform/sensors/campaign_manager.py | 2 +-
.../marketing_platform/sensors/display_video.py | 2 +-
.../marketing_platform/sensors/search_ads.py | 2 +-
airflow/providers/google/provider.yaml | 2 +
airflow/providers/grpc/hooks/grpc.py | 24 +-
airflow/providers/hashicorp/hooks/vault.py | 9 +-
airflow/providers/hashicorp/provider.yaml | 3 +
airflow/providers/http/hooks/http.py | 9 +-
airflow/providers/http/provider.yaml | 3 +
airflow/providers/http/sensors/http.py | 2 +-
airflow/providers/imap/hooks/imap.py | 3 +-
airflow/providers/imap/sensors/imap_attachment.py | 2 +-
.../jdbc/example_dags/example_jdbc_queries.py | 2 +-
airflow/providers/jdbc/hooks/jdbc.py | 27 +-
airflow/providers/jenkins/hooks/jenkins.py | 9 +-
airflow/providers/jenkins/provider.yaml | 3 +
airflow/providers/jira/hooks/jira.py | 3 +-
airflow/providers/jira/sensors/jira.py | 2 +-
airflow/providers/microsoft/azure/hooks/adx.py | 9 +-
.../providers/microsoft/azure/hooks/azure_batch.py | 3 +-
.../azure/hooks/azure_container_instance.py | 7 +-
.../azure/hooks/azure_container_registry.py | 2 +-
.../azure/hooks/azure_container_volume.py | 2 +-
.../microsoft/azure/hooks/azure_cosmos.py | 3 +-
.../microsoft/azure/hooks/azure_data_lake.py | 3 +-
.../microsoft/azure/hooks/azure_fileshare.py | 2 +-
.../providers/microsoft/azure/hooks/base_azure.py | 7 +-
airflow/providers/microsoft/azure/hooks/wasb.py | 3 +-
airflow/providers/microsoft/azure/provider.yaml | 3 +
.../microsoft/azure/sensors/azure_cosmos.py | 2 +-
airflow/providers/microsoft/azure/sensors/wasb.py | 2 +-
airflow/providers/microsoft/mssql/hooks/mssql.py | 3 +-
.../microsoft/winrm/example_dags/example_winrm.py | 2 +-
airflow/providers/microsoft/winrm/hooks/winrm.py | 2 +-
airflow/providers/mongo/hooks/mongo.py | 3 +-
airflow/providers/mongo/sensors/mongo.py | 2 +-
airflow/providers/mysql/hooks/mysql.py | 3 +-
airflow/providers/odbc/hooks/odbc.py | 5 +-
airflow/providers/openfaas/hooks/openfaas.py | 2 +-
airflow/providers/oracle/hooks/oracle.py | 4 +-
airflow/providers/pagerduty/hooks/pagerduty.py | 2 +-
airflow/providers/plexus/hooks/plexus.py | 2 +-
airflow/providers/postgres/hooks/postgres.py | 3 +-
.../{cncf/kubernetes => presto}/ADDITIONAL_INFO.md | 12 +-
airflow/providers/presto/hooks/presto.py | 3 +-
.../qubole/example_dags/example_qubole.py | 2 +-
airflow/providers/qubole/hooks/qubole.py | 21 +-
airflow/providers/qubole/operators/qubole.py | 2 +-
airflow/providers/qubole/provider.yaml | 3 +
airflow/providers/qubole/sensors/qubole.py | 4 +-
airflow/providers/redis/hooks/redis.py | 3 +-
airflow/providers/redis/sensors/redis_key.py | 2 +-
airflow/providers/redis/sensors/redis_pub_sub.py | 2 +-
airflow/providers/salesforce/hooks/salesforce.py | 2 +-
airflow/providers/salesforce/hooks/tableau.py | 3 +-
.../salesforce/sensors/tableau_job_status.py | 2 +-
airflow/providers/samba/hooks/samba.py | 9 +-
airflow/providers/samba/provider.yaml | 3 +
airflow/providers/segment/hooks/segment.py | 7 +-
airflow/providers/segment/provider.yaml | 3 +
airflow/providers/sftp/hooks/sftp.py | 14 +
airflow/providers/sftp/provider.yaml | 3 +
airflow/providers/sftp/sensors/sftp.py | 2 +-
airflow/providers/slack/hooks/slack.py | 2 +-
airflow/providers/snowflake/hooks/snowflake.py | 3 +-
airflow/providers/sqlite/hooks/sqlite.py | 3 +-
airflow/providers/ssh/hooks/ssh.py | 19 +-
airflow/providers/ssh/provider.yaml | 3 +
airflow/providers/telegram/hooks/telegram.py | 2 +-
airflow/providers/vertica/hooks/vertica.py | 3 +-
airflow/providers/yandex/hooks/yandex.py | 68 ++++-
airflow/providers/yandex/provider.yaml | 3 +
airflow/providers/zendesk/hooks/zendesk.py | 2 +-
airflow/providers_manager.py | 192 +++++++++++--
.../sensors/{base_sensor_operator.py => base.py} | 0
airflow/sensors/base_sensor_operator.py | 317 +--------------------
airflow/sensors/bash.py | 2 +-
.../sensors/{date_time_sensor.py => date_time.py} | 2 +-
airflow/sensors/date_time_sensor.py | 60 +---
.../{external_task_sensor.py => external_task.py} | 4 +-
airflow/sensors/external_task_sensor.py | 298 +------------------
airflow/sensors/filesystem.py | 2 +-
airflow/sensors/python.py | 2 +-
.../{smart_sensor_operator.py => smart_sensor.py} | 0
airflow/sensors/{sql_sensor.py => sql.py} | 4 +-
airflow/sensors/sql_sensor.py | 105 +------
.../{time_delta_sensor.py => time_delta.py} | 2 +-
airflow/sensors/time_delta_sensor.py | 32 +--
airflow/sensors/time_sensor.py | 2 +-
airflow/sensors/{weekday_sensor.py => weekday.py} | 2 +-
airflow/serialization/serialized_objects.py | 115 ++++----
airflow/settings.py | 5 +
airflow/smart_sensor_dags/smart_sensor_group.py | 2 +-
airflow/utils/db.py | 77 ++++-
airflow/utils/entry_points.py | 7 +-
airflow/utils/python_virtualenv_script.jinja2 | 12 +
airflow/utils/session.py | 20 +-
airflow/version.py | 4 +-
airflow/www/app.py | 3 +-
airflow/www/extensions/init_views.py | 16 ++
airflow/www/forms.py | 137 +--------
airflow/www/security.py | 2 +-
airflow/www/static/css/bootstrap-theme.css | 8 +-
airflow/www/static/css/dags.css | 2 +-
airflow/www/static/css/main.css | 2 +-
airflow/www/static/css/switch.css | 11 +-
airflow/www/static/js/connection_form.js | 59 +---
airflow/www/templates/airflow/conn_create.html | 1 +
airflow/www/templates/airflow/conn_edit.html | 1 +
airflow/www/templates/airflow/dag.html | 13 +-
airflow/www/templates/airflow/dags.html | 11 +-
airflow/www/templates/appbuilder/flash.html | 17 +-
airflow/www/templates/appbuilder/navbar_menu.html | 5 +-
airflow/www/views.py | 99 +++++--
.../templates/scheduler/scheduler-deployment.yaml | 2 +-
.../templates/webserver/webserver-deployment.yaml | 2 +-
chart/tests/test_basic_helm_chart.py | 2 -
dags/test_dag.py | 2 +-
dev/README_RELEASE_AIRFLOW.md | 40 ++-
dev/README_RELEASE_PROVIDER_PACKAGES.md | 57 +++-
dev/provider_packages/prepare_provider_packages.py | 4 +-
.../refactor_provider_packages.py | 10 +
docs/apache-airflow-providers-amazon/index.rst | 1 +
.../logging/cloud-watch-task-handlers.rst} | 36 +--
.../logging/index.rst | 4 +-
.../logging/s3-task-handler.rst | 49 ++++
.../index.rst | 6 +
.../logging.rst | 102 +++++++
.../logging/index.rst | 4 +-
.../index.rst | 1 +
.../logging.rst | 55 ++++
.../connections/odbc.rst | 2 +-
docs/apache-airflow/cli-and-env-variables-ref.rst | 1 -
docs/apache-airflow/concepts.rst | 16 +-
docs/apache-airflow/howto/custom-operator.rst | 6 +-
.../howto/operator/external_task_sensor.rst | 2 +-
docs/apache-airflow/howto/set-config.rst | 1 -
docs/apache-airflow/lineage.rst | 2 +-
.../logging-monitoring/logging-tasks.rst | 181 ------------
docs/apache-airflow/logging-monitoring/metrics.rst | 2 +-
docs/apache-airflow/operators-and-hooks-ref.rst | 14 +-
docs/apache-airflow/plugins.rst | 2 +-
docs/apache-airflow/production-deployment.rst | 47 ++-
docs/apache-airflow/python-api-ref.rst | 10 +-
docs/apache-airflow/rest-api-ref.rst | 5 +
docs/apache-airflow/scheduler.rst | 32 +++
docs/apache-airflow/security/access-control.rst | 5 +-
docs/apache-airflow/tutorial_taskflow_api.rst | 13 +-
docs/build_docs.py | 182 ++----------
docs/exts/airflow_intersphinx.py | 21 +-
docs/exts/docs_build/code_utils.py | 13 +-
.../exts/docs_build/dev_index_template.html.jinja2 | 18 ++
docs/exts/docs_build/docs_builder.py | 206 +++++++++++++
.../exts/docs_build/github_action_utils.py | 26 +-
.../operators_and_hooks_ref-transfers.rst.jinja2 | 18 ++
docs/exts/operators_and_hooks_ref.rst.jinja2 | 18 ++
docs/publish_docs.py | 100 +++++++
docs/spelling_wordlist.txt | 2 +
docs/upgprade-check/upgrade-check.rst | 163 +++++++++++
pyproject.toml | 16 ++
scripts/ci/dockerfiles/krb5-kdc-server/Dockerfile | 16 ++
scripts/ci/dockerfiles/krb5-kdc-server/kadm5.acl | 16 ++
scripts/ci/dockerfiles/presto/Dockerfile | 16 ++
scripts/ci/images/ci_build_dockerhub.sh | 64 +++--
scripts/ci/images/ci_prepare_prod_image_on_ci.sh | 54 +---
scripts/ci/libraries/_build_images.sh | 39 +++
scripts/ci/libraries/_initialization.sh | 26 ++
scripts/ci/libraries/_kind.sh | 3 +-
scripts/in_container/prod/entrypoint_prod.sh | 29 +-
.../run_install_and_test_provider_packages.sh | 56 +++-
scripts/tools/list-integrations.py | 4 +-
setup.cfg | 11 +-
setup.py | 101 ++++---
tests/api/auth/backend/test_basic_auth.py | 8 +-
tests/api/common/experimental/test_delete_dag.py | 2 +-
tests/api_connexion/endpoints/test_dag_endpoint.py | 2 +-
.../endpoints/test_event_log_endpoint.py | 2 +-
tests/api_connexion/endpoints/test_log_endpoint.py | 2 +-
.../api_connexion/endpoints/test_task_endpoint.py | 8 +-
.../api_connexion/schemas/test_event_log_schema.py | 2 +-
.../schemas/test_task_instance_schema.py | 2 +-
tests/api_connexion/schemas/test_task_schema.py | 6 +-
tests/cli/commands/test_plugins_command.py | 2 +-
tests/core/test_configuration.py | 6 +-
tests/core/test_core.py | 4 +-
tests/core/test_providers_manager.py | 73 ++++-
tests/dags/test_backfill_pooled_tasks.py | 2 +-
tests/dags/test_clear_subdag.py | 2 +-
tests/dags/test_dag_with_no_tags.py | 2 +-
tests/dags/test_double_trigger.py | 2 +-
tests/dags/test_example_bash_operator.py | 2 +-
tests/dags/test_impersonation_subdag.py | 2 +-
tests/dags/test_invalid_cron.py | 2 +-
tests/dags/test_issue_1225.py | 2 +-
tests/dags/test_latest_runs.py | 2 +-
tests/dags/test_missing_owner.py | 2 +-
tests/dags/test_on_failure_callback.py | 2 +-
tests/dags/test_on_kill.py | 2 +-
tests/dags/test_only_dummy_tasks.py | 2 +-
tests/dags/test_prev_dagrun_dep.py | 2 +-
tests/dags/test_scheduler_dags.py | 2 +-
tests/dags/test_subdag.py | 4 +-
tests/dags/test_with_non_default_owner.py | 2 +-
.../dags_with_system_exit/b_test_scheduler_dags.py | 2 +-
tests/deprecated_classes.py | 34 ++-
tests/hooks/{test_dbapi_hook.py => test_dbapi.py} | 15 +-
tests/jobs/test_backfill_job.py | 2 +-
tests/jobs/test_local_task_job.py | 2 +-
tests/jobs/test_scheduler_job.py | 4 +-
tests/kubernetes/test_pod_generator.py | 8 +-
tests/lineage/test_lineage.py | 2 +-
tests/models/test_baseoperator.py | 2 +-
tests/models/test_cleartasks.py | 2 +-
tests/models/test_connection.py | 2 +-
tests/models/test_dag.py | 4 +-
tests/models/test_dagbag.py | 55 +++-
tests/models/test_dagrun.py | 2 +-
tests/models/test_pool.py | 2 +-
tests/models/test_renderedtifields.py | 2 +-
tests/models/test_skipmixin.py | 2 +-
tests/models/test_taskinstance.py | 10 +-
tests/models/test_timestamp.py | 2 +-
tests/operators/test_branch_operator.py | 4 +-
tests/operators/test_dagrun_operator.py | 2 +-
tests/operators/test_latest_only_operator.py | 2 +-
tests/operators/test_python.py | 2 +-
tests/operators/test_sql.py | 2 +-
tests/operators/test_subdag_operator.py | 8 +-
tests/plugins/test_plugin.py | 4 +-
tests/plugins/test_plugins_manager.py | 54 +++-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 2 +-
.../amazon/aws/log/test_s3_task_handler.py | 2 +-
.../amazon/aws/operators/test_emr_add_steps.py | 2 +-
.../elasticsearch/log/test_es_task_handler.py | 2 +-
tests/providers/facebook/ads/hooks/test_ads.py | 2 +-
tests/providers/google/ads/hooks/test_ads.py | 2 +-
.../providers/google/cloud/hooks/test_dataprep.py | 2 +-
.../google/cloud/log/test_gcs_task_handler.py | 2 +-
.../cloud/log/test_stackdriver_task_handler.py | 2 +-
.../google/cloud/operators/test_cloud_sql.py | 4 +-
.../cloud/operators/test_kubernetes_engine.py | 4 +-
.../common/auth_backend/test_google_openid.py | 5 +-
tests/providers/google/suite/hooks/test_drive.py | 2 +-
tests/providers/grpc/hooks/test_grpc.py | 24 +-
tests/providers/http/hooks/test_http.py | 44 +--
tests/providers/jenkins/hooks/test_jenkins.py | 4 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 2 +-
.../providers/microsoft/mssql/hooks/test_mssql.py | 6 +-
.../microsoft/mssql/operators/test_mssql.py | 2 +-
tests/providers/openfaas/hooks/test_openfaas.py | 2 +-
tests/providers/presto/hooks/test_presto.py | 19 +-
tests/providers/samba/hooks/test_samba.py | 8 +-
tests/providers/ssh/hooks/test_ssh.py | 8 +
tests/providers/vertica/hooks/test_vertica.py | 2 +-
tests/providers/yandex/hooks/test_yandex.py | 6 +-
.../yandex/hooks/test_yandexcloud_dataproc.py | 2 +-
.../yandex/operators/test_yandexcloud_dataproc.py | 12 +-
.../sensors/{test_base_sensor.py => test_base.py} | 4 +-
...{test_date_time_sensor.py => test_date_time.py} | 4 +-
tests/sensors/test_external_task_sensor.py | 4 +-
tests/sensors/test_smart_sensor_operator.py | 6 +-
tests/sensors/test_sql_sensor.py | 18 +-
...test_timedelta_sensor.py => test_time_delta.py} | 2 +-
tests/sensors/test_timeout_sensor.py | 2 +-
tests/sensors/test_weekday_sensor.py | 2 +-
tests/serialization/test_dag_serialization.py | 6 +-
.../test_remote_user_api_auth_backend.py | 4 +-
.../deps/test_not_previously_skipped_dep.py | 2 +-
tests/ti_deps/deps/test_runnable_exec_date_dep.py | 2 +-
tests/ti_deps/deps/test_trigger_rule_dep.py | 2 +-
tests/utils/log/test_log_reader.py | 2 +-
tests/utils/test_dag_cycle.py | 2 +-
tests/utils/test_helpers.py | 2 +-
tests/utils/test_log_handlers.py | 2 +-
tests/utils/test_task_group.py | 2 +-
.../test_task_handler_with_custom_formatter.py | 2 +-
.../www/api/experimental/test_dag_runs_endpoint.py | 8 +-
tests/www/api/experimental/test_endpoints.py | 2 +
.../api/experimental/test_kerberos_endpoints.py | 1 +
tests/www/test_init_views.py | 39 +++
tests/www/test_views.py | 2 +-
428 files changed, 3627 insertions(+), 2906 deletions(-)
create mode 100644 airflow/customized_form_field_behaviours.schema.json
create mode 100644 airflow/hooks/base.py
copy airflow/hooks/{dbapi_hook.py => dbapi.py} (98%)
copy airflow/migrations/versions/{2e541a1dcfed_task_duration.py => e959f08ac86c_change_field_in_dagcode_to_mediumtext_.py} (62%)
copy airflow/operators/{branch_operator.py => branch.py} (100%)
copy airflow/operators/{dummy_operator.py => dummy.py} (100%)
copy airflow/operators/{subdag_operator.py => subdag.py} (98%)
copy airflow/providers/{cncf/kubernetes => presto}/ADDITIONAL_INFO.md (55%)
copy airflow/sensors/{base_sensor_operator.py => base.py} (100%)
copy airflow/sensors/{date_time_sensor.py => date_time.py} (97%)
copy airflow/sensors/{external_task_sensor.py => external_task.py} (99%)
rename airflow/sensors/{smart_sensor_operator.py => smart_sensor.py} (100%)
copy airflow/sensors/{sql_sensor.py => sql.py} (97%)
copy airflow/sensors/{time_delta_sensor.py => time_delta.py} (96%)
rename airflow/sensors/{weekday_sensor.py => weekday.py} (98%)
copy docs/{apache-airflow/security/flower.rst => apache-airflow-providers-amazon/logging/cloud-watch-task-handlers.rst} (50%)
copy docs/{apache-airflow-providers-google => apache-airflow-providers-amazon}/logging/index.rst (95%)
create mode 100644 docs/apache-airflow-providers-amazon/logging/s3-task-handler.rst
create mode 100644 docs/apache-airflow-providers-elasticsearch/logging.rst
create mode 100644 docs/apache-airflow-providers-microsoft-azure/logging.rst
create mode 100644 docs/exts/docs_build/docs_builder.py
copy airflow/www/extensions/init_dagbag.py => docs/exts/docs_build/github_action_utils.py (58%)
create mode 100755 docs/publish_docs.py
create mode 100644 docs/upgprade-check/upgrade-check.rst
rename tests/hooks/{test_dbapi_hook.py => test_dbapi.py} (91%)
rename tests/sensors/{test_base_sensor.py => test_base.py} (99%)
rename tests/sensors/{test_date_time_sensor.py => test_date_time.py} (95%)
rename tests/sensors/{test_timedelta_sensor.py => test_time_delta.py} (96%)
create mode 100644 tests/www/test_init_views.py