This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch v2-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git.
omit 63b1c27 Bump version to 2.2.0b2
add bbb5fe2 Fix ``docker-stack`` docs build (#18419)
add a99e9b5 Add Opus Interactive to INTHEWILD (#18423)
add edee250 Add driver parameter for MsSQL URL for production image in
docs (#18426)
add 92e7759 Chart Doc: Delete extra space in adding connections doc
(#18424)
add cbb1f5a add extraContainers for migrateDatabaseJob (#18379)
add bfc78d1 Fix image retagging when pulling the images (#18433)
add 1849d4d Switch to latest version of PGBouncer-Exporter (#18429)
add 414f41e Custom timetable must return aware datetimes (#18420)
add 13a558d Add cascade to DagRun/TaskInstance relationship (#18434)
add 56d1765 Properly fix dagrun update state endpoint (#18370)
add d50cfd1 Fix task instance url in webserver utils (#18418)
add 3db4656 Protect agains images not being pulled properly (#18435)
add 7e7fa62 Limit azure-storage-blob due to breaking changes in 12.9.0
(#18443)
add 716c635 Doc: Fix remote name in Airflow publishing guide (#18451)
add 7924249 Avoid importing DAGs during clean DB installation (#18450)
add 6dbeb82 Allow users to submit bugs for 2.2.0b2 (#18452)
add c1f34bd Remove unnecessary css state colors (#18461)
add deb01dd Fix task group tooltip (#18406)
add 0359fc1 Add fixing of ownership also for sources in Breeze (#18464)
add 2a3cbab Cope with `@task.docker` decorated function not returning
anything (#18463)
add 0e58de7 Bring back version to docker-compose files (#18472)
add 958b679 Revert "Fix task instance url in webserver utils" and fix
properly (#18444)
add 9bf0ed2 Restore 'filename' to template_fields (#18466)
add a5439ee Add index to the dataset name to have separate dataset for
each example DAG (#18459)
add 1ef41be Correctly select ``DagRun.execution_date`` from db (#18421)
add a74c94c Added Zalando to ``INTHEWILD.md`` (#18480)
add e81c7df Remove redundant ``session.commit()`` in migration (#18453)
add 381a839 Update best practices around deleting a task (#18483)
add 7006068 Doc: Fix example timetable for AIP-39 howto (#18475)
add 7ce29f5 Docs: Fix grammar in ``docs/apache-airflow/start/docker.rst``
(#18484)
add df13147 Chart: warn when webserver secret key isn't set (#18306)
add 1d2924c Proper handling of Account URL custom conn field in
AzureBatchHook (#18456)
add 6609e9a Add start date to ``trigger_dagrun`` operator (#18226)
add 56a69b7 Pin ``google-cloud-dataproc`` to ``<2.6.0`` due to removal of
``v1beta2`` client (#18486)
add 3857aa8 Implement test to detect actions that are missing required
security decorator. (#18467)
add 18e91bc Don't use flash for "same-page" UI messages. (#18462)
add 96f09b1 Add more informative messages when rebuilding the image
(#18496)
add ac4acf9 Increase timeouts for setup/teardown in pytest (#18505)
add be82001 Add missing email type of connection (#18502)
add 8c2e329 Add ok.ru into the list of airflow users (#18507)
add 7ecca70 Add Pathstream to INTHEWILD.md (#18508)
add 6982a29 Add missing type of tests to breeze. (#18504)
add f1ea87a Chart: 1.2.0 changelog (#18510)
add 97d6892 Rename AzureDataLakeStorage to ADLS (#18493)
add da15121 Improve guidance to users telling them what to do on import
timeout (#18478)
add 31c7ef5 Add setting up using VS Code (#15631)
add 2f44f0b 18400 chart custom pod annotations (#18481)
add c1578fb Improve error message for BranchPythonOperator when no
task_id to follow (#18471)
add 4648446 Removing redundant relabeling of password conn field (#18386)
add f37c360 Add Dcard to the list of companies using Airflow (#18521)
add 7b7661a Fixed naming in the Spark Connection Extra field (#18469)
add e50dc9e Added notification to solve "docker-credential-service-error"
(#18524)
add 7c9aba5 Inherit `AirflowNotFound` from `connextion.NotFound` for
better readability (#18523)
add 29493d2 Add Slack operators how-to guide (#18525)
add 2643345 Add guide for Apache Druid operators (#18527)
add dc3bf42 Fix running helm tests in parallel (#18533)
add 932c3b5 Improve isolation of MSSQL files (#18538)
add fa1a088 Remove workaround for docker-compose-failures (#18539)
add 387c43f Fix intermittent orphan test (#18530)
add 391da64 Excludes rightfullhy unlicensed files from chart from RAT
check (#18547)
add a458fcc Updating miscellaneous provider DAGs to use TaskFlow API
where applicable (#18278)
add 2fadf3c Fix kubernetes engine system test (#18548)
add 892c5fc Add package filter info to Breeze build docs (#18550)
add 80ae70c Fix ``DetachedInstanceError`` when dag_run attrs are accessed
from ti (#18499)
add de9b02f Updating the Elasticsearch example DAG to use the TaskFlow
API (#18565)
add 1e5d5e3 Allow core Triggerer loops to yield control (#18552)
add 4281e51 Doc: Fix typo in Triggerer docs (#18560)
add 34396ad Fetch PR labels from API for Build Images workflow (#18572)
add 273e9b2 Give MSSQL container more time to start up (#18476)
add b0a2977 Fix flaky redis tests (#18537)
add 1ac63cd Fix rendering nested task fields (#18516)
add 806e4bc Adding `task_group` to the BaseOperator docstring (#18564)
add 45e8191 Allow airflow standard images to run in openshift utilising
the official helm chart #18136 (#18147)
add 4f3aa43 Change location of bucket creation for Datastore (#18569)
add 2fbd238 Update s3_list.py (#18561)
add 48d4c5d Move FABs base Security Manager into Airflow. (#16647)
add d0cc912 Operator help code optimisation (#18571)
add 24e57d6 Add in Bidnamic to INTHEWILD.md (#18589)
add c747bce Influxdb Hook (#17068)
add 1b42766 Add Macquarie Group to the list of companies using Airflow
(#18591)
add 05fb915 Fixing flaky test that fails when run with other test that
leave a trace (#18586)
add 2187008 Small typo in JdbcOperator (#18593)
add f467a8e Only show the task modal if it is a valid instance (#18570)
add ca93ff4 Fix errors upgrading from Airflow 1.10.15 (#18573)
add 90cb45b De-dup and reorganize render template tests (#18432)
add 461ec4c Bugfix: dag_bag.get_dag should not raise exception (#18554)
add 9279c44 Fix part of Google system tests (#18494)
add d50c7ec Fix helm chart links in source install guide (#18588)
add 9133ff4 Chart docs: Update webserver secret key reference
configuration (#18595)
add ffd3cbd Add helm chart 1.2.0 to chart bug issue template (#18609)
add e845275 Updating the InfluxDB example DAG to use the TaskFlow API
(#18596)
add ef037e7 Static start_date and default arg cleanup for misc. provider
example DAGs (#18597)
add 0a8abbf Fix spelling of execution. (#18594)
add afec743 Spelling fix (#18606)
add 26680d4 fix setting task nodes class names (#18607)
add 057cc0a Add in before_send config option to sentry integration
(#18261)
add d2bdf05 Check docker-compose version in breeze (#18536)
add 324aca4 Improve how UI handles datetimes (#18611)
add 339eb0a Update helm chart release docs (#18612)
add 1763180 Fix helm chart unittests on public runners (#18553)
add 8a1437e Refresh credentials for long-running pods on EKS (#17951)
add 0e887dc Change label from area:docs to kind:documentation (#18624)
add 0199c5d Bugfix: Don't warn on using ``LocalExecutor`` (#18625)
add 6e2a317 Fix `retry_exponential_backoff` divide by zero error when
retry delay is zero (#17003)
add c974917 Add multiple roles when creating users (#18617)
add 6ef96a9 Fix typo in comments (#18626)
add abdede8 fix exception string of BranchPythonOperator (#18623)
add b8ce5f0 Revert "Fix intermittent orphan test (#18530)" (#18631)
add b858b98 Combine changelog entires for AIPs 39 and 40 in to a single
row (#18633)
add 4f16163 Adding a default conn ID value for Apache Cassandra sensors
(#18620)
add ef71c35 Added VLMedia to INTHEWILD (#18636)
add 33bdd3d Updating ADX conn docs to reflect new custom fields (#18132)
add 840ea3e Update documentation for September providers release (#18613)
add d0ffd31 Fix flaky test `test_set_dag_runs_action` (#18618)
add d79f506 Add default weight rule configuration option (#18627)
add 5db757a Update changelog for changes since 2.2.0b2 (#18639)
add b6aa8d5 Fix typo change GitHyb to GitHub (#18640)
add db2d73d Retry deadlocked transactions on deleting old rendered task
fields (#18616)
add 932a225 Add muldelete action to TaskInstanceModelView (#18438)
add 0a37be3 Add region to Snowflake URI. (#18650)
add d74e677 Make AirflowDateTimePickerWidget a required field (#18602)
add 3e409fa Fix section formatting in the "Customizing the UI" docs page
(#18658)
add 87dc63b Remove empty doc from influxdb provider (#18647)
add 8dfb6a7 Fix stop_airflow typos in CONTRIBUTORS_QUICK_START.rst
(#18656)
add 4f9b097 Patch `utcnow` in retry delay test (#18343)
add af4a5e0 Remove cargo-culted local in-page ToCs (#18668)
add 2f88009 Fix error on triggering a dag that doesn't exist using
dagrun_conf (#18655)
add 1213386 Support all Unix wildcards in S3KeySensor (#18211)
add 3172be0 Check the allowed values for the logging level (#18651)
add 10421c6 update azure cosmos version (#18663)
add 2bcd674 Added Viscovery to the list of companies using Apache Airflow
(#18683)
add c8485a8 Revert "update azure cosmos version (#18663)" (#18694)
add 3a59a85 Correcting text in core extenders docs (#18661)
add 6d504b4 Expanding docs on client auth for AzureKeyVaultBackend
(#18659)
add 7efee00 Typo in docs/apache-airflow/installation/index.rst (#18689)
add f8c31b5 Add max_ingestion_time to DruidOperator docstring (#18693)
add 8fa976e Add formatDateTime back into ti log (#18700)
add 86bf2a2 Simplify strings previously split across lines (#18679)
add 2630341 Fix compatibility issues with docker-compose 2 (#18725)
add 0355d3f Fix eager-upgrade builds for Airflow main. (#18719)
add c596ef4 Add example DAG using TimeDeltaSensorAsync (#18728)
add cc52548 Dockerfile: Fix env variable typo
``_AIRFLOW_WWW_USER_LASTNME`` (#18727)
add 385b4a4 Add ``DaskExecutor`` queue handling change to ``UPDATING.md``
(#18720)
add 181ac36 update azure cosmos to latest version (#18695)
add a834dee Ensure task_instance exists before running update on its
state(REST API) (#18642)
add 6b71eac Renaming variables to be consistent with code logic (#18685)
add b0442f3 Handle timetable exception in ``DAG.next_dagrun_info``
(#18729)
add 29aa7f0 Properly set start_date for cleared tasks (#18708)
add 016f55c Pretty print diff for order checks (#18686)
add 537963f update minimum version of sshtunnel to 0.3.2 (#18684)
add 5f7fc59 Add google-ads limitation to eager upgrade (#18741)
add 12763f1 Add additional dependency for postgres extra for amazon
provider (#18737)
add 1b75f91 Fix changelog for Azure Provider (#18736)
add 57bb47f Updates link to "stable" URLs for providers "installing from
sources" (#18735)
add 4e10c25 Rename ``processor_poll_interval`` to
``scheduler_idle_sleep_time`` (#18704)
add cf1f6e1 Fix typos in IMAGES.rst, README_RELEASE_PROVIDER_PACKAGES.md
and REFRESHING_CI_CACHE.md (#18751)
add 1697617 Don't ignore legacy `concurrency` dag parameter (#18730)
add 760bf6e Adds an s3 list prefixes operator (#17145)
add 2c2bbb5 Fix "Test" connection button when app not mounted at `/`
(#18750)
add 958860f Remove AIRFLOW_GID from Docker images (#18747)
add 9eae83c Remove eagerloading when querying for TI (#18706)
add a192b4a Chart: Mount DAGs in triggerer (#18753)
add 767a4f5 ECSOperator: airflow exception on edge case when cloudwatch
log stream is not found (#18733)
add 2a6cadb Small improvements for Airflow UI (#18715)
add c9bf5f3 Coerce datetime to pendulum for timetable (#18522)
add cf27419 Fix Pendulum 1.x references in documentation (#18766)
add a36e7ba Make REST API patch user endpoint work the same way as the UI
(#18757)
add 72e49ad Amazon SQS Example (#18760)
add cdb34a4 Quarantine iest_no_orphan_process_will_be_left (#18778)
add 43f334f Move docker decorator example dag to docker provider (#18739)
add 5306a60 Bump pre-commits: `black` and `pyupgrade` (#18782)
add cfc2e1b Always run at least one backfill from BackfillJob (#18742)
add e351ead Change the color for deferred status to mediumpurple (#18414)
add 32947a4 Fix deprecated default for ``fab_logging_level`` to
``WARNING`` (#18783)
add dc45f97 Adds CeleryKubernetesExecutor check to AirflowBaseView.run
(#18441)
add 63ca12c Open src and dst in binary for samba copy (#18752)
add 38c6cf9 AwsGlueJobOperator: add run_job_kwargs to Glue job run
(#16796)
add 28284a3 Amazon Athena Example (#18785)
add e15e79b Adds Hacktoberfest label to participate in Hacktoberfest 2021
(#18781)
add 9a5ac14 Fix bug that backfill job fail to run when there are tasks
run into reschedue state (#17305)
add cfa8fe2 UI: Fix alignment of Delete Button (#18795)
add 6bc0f87 Properly handle verify parameter in TrinoHook (#18791)
add 6103b26 Stabilize flaky
test_extra_operator_links_not_loaded_in_scheduler_loop (#18796)
add 20df60d Dataflow Operators - use project and location from job in
on_kill method. (#18699)
add 8d7340b Stabilize flaky
test_do_schedule_max_active_runs_dag_timed_out (#18531)
add c10442e Backport fix to allow pickling of Loggers to Python 3.6
(#18798)
add 24f549c Docs: Move part of timetable guide to concepts (#18786)
add 953f226 Update changelog with more changes since 2.2.0b2 (#18780)
add b70fded Fix flaky test_external_task_marker_cyclic_deep test (#18802)
add 5bc64fb Update instructions to create Airflow release (#18809)
add cdaa9aa Accept custom run ID in ``TriggerDagRunOperator`` (#18788)
new c1dc3bf Bump version to 2.2.0b2
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 (63b1c27)
\
N -- N -- N refs/heads/v2-2-test (c1dc3bf)
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.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 1 +
.github/ISSUE_TEMPLATE/airflow_bug_report.yml | 2 +-
.../ISSUE_TEMPLATE/airflow_doc_issue_report.yml | 2 +-
.../airflow_helmchart_bug_report.yml | 3 +-
.../airflow_providers_bug_report.yml | 1 +
.github/workflows/build-images.yml | 22 +-
.pre-commit-config.yaml | 7 +-
.rat-excludes | 6 +
BREEZE.rst | 13 +-
CHANGELOG.txt | 103 +-
CONTRIBUTING.rst | 2 +-
CONTRIBUTORS_QUICK_START.rst | 918 +++++++++-
Dockerfile | 18 +-
Dockerfile.ci | 3 +-
IMAGES.rst | 2 +-
INSTALL | 2 +-
INTHEWILD.md | 9 +
NOTICE | 8 +
TESTING.rst | 38 +-
UPDATING.md | 27 +-
airflow/api/common/experimental/mark_tasks.py | 1 -
airflow/api/common/experimental/trigger_dag.py | 14 +-
airflow/api_connexion/endpoints/dag_endpoint.py | 9 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 22 +-
airflow/api_connexion/endpoints/log_endpoint.py | 2 -
.../endpoints/role_and_permission_endpoint.py | 2 +-
.../endpoints/task_instance_endpoint.py | 28 +-
airflow/api_connexion/endpoints/user_endpoint.py | 33 +-
airflow/api_connexion/openapi/v1.yaml | 4 +
airflow/cli/commands/dag_command.py | 10 +-
airflow/cli/commands/user_command.py | 7 +-
airflow/config_templates/config.yml | 24 +-
airflow/config_templates/default_airflow.cfg | 15 +-
.../config_templates/default_webserver_config.py | 10 +-
airflow/configuration.py | 46 +-
airflow/contrib/operators/adls_list_operator.py | 22 +-
airflow/dag_processing/processor.py | 2 -
.../example_time_delta_sensor_async.py} | 37 +-
airflow/example_dags/plugins/workday.py | 4 +-
....py => tutorial_taskflow_api_etl_virtualenv.py} | 28 +-
airflow/exceptions.py | 7 +-
airflow/executors/kubernetes_executor.py | 2 +-
airflow/hooks/filesystem.py | 4 +-
airflow/jobs/backfill_job.py | 30 +-
airflow/jobs/local_task_job.py | 4 +-
airflow/jobs/scheduler_job.py | 53 +-
airflow/jobs/triggerer_job.py | 3 +
airflow/logging_config.py | 20 +
...623dc7_add_max_tries_column_to_task_instance.py | 2 +
airflow/models/baseoperator.py | 7 +-
airflow/models/dag.py | 66 +-
airflow/models/dagbag.py | 11 +-
airflow/models/dagrun.py | 4 +-
airflow/models/renderedtifields.py | 34 +-
airflow/models/taskinstance.py | 47 +-
airflow/operators/python.py | 13 +
airflow/operators/trigger_dagrun.py | 29 +-
.../providers/airbyte/.latest-doc-only-change.txt | 2 +-
.../example_dags/example_airbyte_trigger_job.py | 9 +-
.../providers/alibaba/.latest-doc-only-change.txt | 1 +
.../cloud/example_dags/example_oss_bucket.py | 18 +-
.../cloud/example_dags/example_oss_object.py | 19 +-
airflow/providers/amazon/CHANGELOG.rst | 36 +
.../amazon/aws/example_dags/example_athena.py | 150 ++
.../aws/example_dags/example_eks_using_defaults.py | 7 +-
.../amazon/aws/example_dags/example_s3_bucket.py | 11 +-
.../aws/example_dags/example_s3_to_redshift.py | 31 +-
.../amazon/aws/example_dags/example_sqs.py | 85 +
airflow/providers/amazon/aws/hooks/eks.py | 39 +-
airflow/providers/amazon/aws/hooks/glue.py | 9 +-
airflow/providers/amazon/aws/hooks/s3.py | 2 +-
airflow/providers/amazon/aws/hooks/ses.py | 2 +-
airflow/providers/amazon/aws/operators/athena.py | 4 +
airflow/providers/amazon/aws/operators/ecs.py | 21 +-
airflow/providers/amazon/aws/operators/glue.py | 6 +-
airflow/providers/amazon/aws/operators/s3_list.py | 2 +-
.../operators/{s3_list.py => s3_list_prefixes.py} | 31 +-
airflow/providers/amazon/aws/operators/sqs.py | 4 +
airflow/providers/amazon/aws/sensors/s3_key.py | 2 +-
.../providers/amazon/aws/utils/eks_get_token.py | 69 +
airflow/providers/amazon/provider.yaml | 9 +
airflow/providers/apache/cassandra/CHANGELOG.rst | 11 +
airflow/providers/apache/cassandra/provider.yaml | 1 +
.../providers/apache/cassandra/sensors/record.py | 9 +-
.../providers/apache/cassandra/sensors/table.py | 4 +-
.../apache/druid/.latest-doc-only-change.txt | 2 +-
.../apache/druid/example_dags}/__init__.py | 0
.../druid/example_dags/example_druid_dag.py} | 52 +-
airflow/providers/apache/druid/operators/druid.py | 2 +
airflow/providers/apache/druid/provider.yaml | 4 +-
airflow/providers/apache/hdfs/CHANGELOG.rst | 11 +
airflow/providers/apache/hdfs/provider.yaml | 1 +
.../apache/hive/.latest-doc-only-change.txt | 2 +-
.../hive/example_dags/example_twitter_README.md | 2 +-
.../hive/example_dags/example_twitter_dag.py | 134 +-
.../apache/kylin/.latest-doc-only-change.txt | 2 +-
.../apache/kylin/example_dags/example_kylin_dag.py | 64 +-
.../providers/asana/.latest-doc-only-change.txt | 2 +-
.../providers/asana/example_dags/example_asana.py | 9 +-
airflow/providers/cncf/kubernetes/CHANGELOG.rst | 16 +
.../kubernetes/example_dags/example_kubernetes.py | 5 +-
.../example_dags/example_spark_kubernetes.py | 17 +-
airflow/providers/cncf/kubernetes/provider.yaml | 1 +
airflow/providers/databricks/CHANGELOG.rst | 11 +
.../databricks/example_dags/example_databricks.py | 13 +-
airflow/providers/databricks/provider.yaml | 1 +
.../providers/dingding/.latest-doc-only-change.txt | 2 +-
.../dingding/example_dags/example_dingding.py | 17 +-
airflow/providers/docker/CHANGELOG.rst | 20 +
.../docker/example_dags/example_docker.py | 16 +-
.../example_dags/example_docker_copy_data.py | 16 +-
.../docker/example_dags/example_docker_swarm.py | 12 +-
.../tutorial_taskflow_api_etl_docker_virtualenv.py | 14 +-
airflow/providers/docker/operators/docker.py | 3 +
airflow/providers/docker/provider.yaml | 1 +
.../elasticsearch/.latest-doc-only-change.txt | 1 +
.../example_dags/example_elasticsearch_query.py | 17 +-
airflow/providers/google/CHANGELOG.rst | 37 +
.../cloud/example_dags/example_bigquery_queries.py | 49 +-
.../cloud/example_dags/example_cloud_build.py | 2 +-
.../cloud/example_dags/example_cloud_sql_query.py | 2 +-
.../cloud/example_dags/example_datacatalog.py | 7 +-
.../google/cloud/example_dags/example_dataflow.py | 18 +-
.../cloud/example_dags/example_datafusion.py | 20 +-
.../google/cloud/example_dags/example_functions.py | 2 +-
.../example_dags/example_kubernetes_engine.py | 2 +
.../google/cloud/example_dags/example_s3_to_gcs.py | 7 +-
.../cloud/hooks/cloud_storage_transfer_service.py | 2 +-
airflow/providers/google/cloud/hooks/dataflow.py | 59 +-
airflow/providers/google/cloud/hooks/datafusion.py | 4 +-
.../google/cloud/hooks/kubernetes_engine.py | 2 +-
airflow/providers/google/cloud/hooks/mlengine.py | 4 +-
airflow/providers/google/cloud/hooks/spanner.py | 2 +-
.../providers/google/cloud/operators/dataflow.py | 48 +-
.../providers/google/cloud/sensors/datafusion.py | 10 +
.../google/cloud/transfers/adls_to_gcs.py | 4 +-
.../providers/google/common/hooks/base_google.py | 6 +-
airflow/providers/google/provider.yaml | 1 +
airflow/providers/hashicorp/CHANGELOG.rst | 13 +-
airflow/providers/hashicorp/provider.yaml | 1 +
airflow/providers/http/.latest-doc-only-change.txt | 2 +-
.../providers/http/example_dags/example_http.py | 11 +-
.../providers/influxdb/CHANGELOG.rst | 45 +-
.../providers/influxdb}/__init__.py | 0
.../providers/influxdb/example_dags}/__init__.py | 0
.../influxdb/example_dags/example_influxdb.py | 57 +
.../providers/influxdb}/hooks/__init__.py | 0
airflow/providers/influxdb/hooks/influxdb.py | 163 ++
.../{papermill => influxdb}/provider.yaml | 32 +-
airflow/providers/jdbc/.latest-doc-only-change.txt | 2 +-
.../jdbc/example_dags/example_jdbc_queries.py | 13 +-
.../providers/jenkins/.latest-doc-only-change.txt | 2 +-
.../example_dags/example_jenkins_job_trigger.py | 22 +-
airflow/providers/microsoft/azure/CHANGELOG.rst | 37 +
.../azure/example_dags/example_adls_delete.py | 6 +-
.../azure/example_dags/example_fileshare.py | 9 +-
.../azure/example_dags/example_local_to_adls.py | 6 +-
airflow/providers/microsoft/azure/hooks/adx.py | 1 -
.../providers/microsoft/azure/hooks/azure_batch.py | 33 +-
.../microsoft/azure/hooks/azure_cosmos.py | 6 +-
.../azure/operators/{adls_delete.py => adls.py} | 45 +-
.../microsoft/azure/operators/adls_delete.py | 55 +-
.../microsoft/azure/operators/adls_list.py | 57 +-
airflow/providers/microsoft/azure/provider.yaml | 2 +
.../microsoft/azure/secrets/azure_key_vault.py | 10 +
.../providers/mysql/.latest-doc-only-change.txt | 2 +-
.../providers/mysql/example_dags/example_mysql.py | 10 +-
airflow/providers/neo4j/CHANGELOG.rst | 12 +
.../providers/neo4j/example_dags/example_neo4j.py | 8 +-
airflow/providers/neo4j/provider.yaml | 1 +
airflow/providers/openfaas/hooks/openfaas.py | 2 +-
airflow/providers/papermill/CHANGELOG.rst | 18 +
.../papermill/example_dags/example_papermill.py | 28 +-
airflow/providers/papermill/provider.yaml | 1 +
.../providers/plexus/.latest-doc-only-change.txt | 2 +-
.../plexus/example_dags/example_plexus.py | 7 +-
airflow/providers/postgres/CHANGELOG.rst | 17 +
.../postgres/example_dags/example_postgres.py | 7 +-
airflow/providers/postgres/provider.yaml | 1 +
.../providers/qubole/.latest-doc-only-change.txt | 2 +-
.../qubole/example_dags/example_qubole.py | 62 +-
airflow/providers/samba/hooks/samba.py | 2 +-
.../singularity/.latest-doc-only-change.txt | 2 +-
.../example_dags/example_singularity.py | 21 +-
airflow/providers/slack/CHANGELOG.rst | 19 +
.../providers/slack/example_dags/example_slack.py | 18 +-
airflow/providers/slack/operators/slack.py | 25 +-
airflow/providers/slack/provider.yaml | 3 +
airflow/providers/snowflake/CHANGELOG.rst | 12 +
.../snowflake/example_dags/example_snowflake.py | 17 +-
airflow/providers/snowflake/hooks/snowflake.py | 2 +-
airflow/providers/snowflake/provider.yaml | 1 +
.../providers/sqlite/.latest-doc-only-change.txt | 2 +-
.../sqlite/example_dags/create_table.sql} | 21 +-
.../sqlite/example_dags/example_sqlite.py | 37 +-
airflow/providers/ssh/CHANGELOG.rst | 11 +
airflow/providers/ssh/hooks/ssh.py | 2 +-
airflow/providers/ssh/provider.yaml | 1 +
.../providers/tableau/.latest-doc-only-change.txt | 2 +-
.../tableau/example_dags/example_tableau.py | 24 +-
.../example_tableau_refresh_workbook.py | 15 +-
.../providers/telegram/.latest-doc-only-change.txt | 2 +-
.../telegram/example_dags/example_telegram.py | 9 +-
airflow/providers/trino/hooks/trino.py | 13 +-
.../providers/yandex/.latest-doc-only-change.txt | 2 +-
.../example_dags/example_yandexcloud_dataproc.py | 10 +-
airflow/sentry.py | 3 +-
airflow/settings.py | 2 +-
airflow/timetables/base.py | 17 +-
airflow/utils/db.py | 4 +-
airflow/utils/file.py | 2 +-
airflow/utils/helpers.py | 2 +-
airflow/utils/operator_helpers.py | 52 +-
airflow/utils/state.py | 4 +-
airflow/utils/timezone.py | 6 +-
airflow/utils/weight_rule.py | 4 +-
.../hooks => airflow/www/fab_security}/__init__.py | 0
airflow/www/fab_security/manager.py | 1822 ++++++++++++++++++++
.../www/fab_security/sqla}/__init__.py | 0
airflow/www/fab_security/sqla/manager.py | 580 +++++++
airflow/www/forms.py | 4 +-
airflow/www/security.py | 2 +-
airflow/www/static/css/graph.css | 57 +-
airflow/www/static/css/main.css | 36 -
airflow/www/static/css/tree.css | 59 +-
airflow/www/static/js/connection_form.js | 3 +-
airflow/www/static/js/dags.js | 4 +-
airflow/www/static/js/datetime_utils.js | 6 -
airflow/www/static/js/graph.js | 99 +-
airflow/www/static/js/task.js | 2 +-
airflow/www/static/js/ti_log.js | 4 +-
.../airflow/{conn_create.html => _messages.html} | 25 +-
airflow/www/templates/airflow/confirm.html | 4 +-
airflow/www/templates/airflow/conn_create.html | 1 +
airflow/www/templates/airflow/conn_edit.html | 1 +
airflow/www/templates/airflow/dag_details.html | 4 +-
airflow/www/templates/airflow/dags.html | 27 +-
airflow/www/templates/airflow/graph.html | 10 +-
airflow/www/templates/airflow/main.html | 9 +-
airflow/www/templates/airflow/task_instance.html | 2 +-
airflow/www/templates/airflow/tree.html | 14 +-
airflow/www/templates/appbuilder/flash.html | 19 +-
airflow/www/utils.py | 2 +-
airflow/www/views.py | 95 +-
airflow/www/widgets.py | 6 +-
breeze | 36 +-
breeze-complete | 2 +-
chart/CHANGELOG.txt | 47 +
chart/templates/NOTES.txt | 14 +
chart/templates/flower/flower-deployment.yaml | 4 +-
chart/templates/jobs/migrate-database-job.yaml | 3 +
.../security-context-constraint-rolebinding.yaml | 86 +
.../templates/scheduler/scheduler-deployment.yaml | 3 +
.../templates/triggerer/triggerer-deployment.yaml | 23 +
.../templates/webserver/webserver-deployment.yaml | 3 +
chart/templates/workers/worker-deployment.yaml | 3 +
chart/tests/test_airflow_common.py | 8 +-
chart/tests/test_annotations.py | 349 +++-
chart/tests/test_configmap.py | 26 +-
chart/tests/test_migrate_database_job.py | 17 +
chart/tests/test_pod_template_file.py | 22 +-
chart/tests/test_scc_rolebinding.py | 116 ++
chart/tests/test_scheduler.py | 16 +-
chart/tests/test_triggerer.py | 28 +
chart/tests/test_webserver.py | 6 +-
chart/tests/test_worker.py | 10 +-
chart/values.schema.json | 39 +-
chart/values.yaml | 35 +-
confirm | 2 +-
dev/README_RELEASE_AIRFLOW.md | 17 +-
dev/README_RELEASE_HELM_CHART.md | 88 +-
dev/README_RELEASE_PROVIDER_PACKAGES.md | 4 +-
dev/REFRESHING_CI_CACHE.md | 2 +-
dev/provider_packages/prepare_provider_packages.py | 4 +-
.../operators/oss.rst | 4 -
docs/apache-airflow-providers-amazon/commits.rst | 31 +-
docs/apache-airflow-providers-amazon/index.rst | 8 +-
.../operators/{ecs.rst => athena.rst} | 28 +-
.../operators/datasync.rst | 4 -
.../operators/dms.rst | 4 -
.../operators/ecs.rst | 4 -
.../operators/eks.rst | 5 -
.../operators/emr.rst | 4 -
.../operators/emr_eks.rst | 4 -
.../operators/google_api_to_s3_transfer.rst | 4 -
.../operators/imap_attachment_to_s3.rst | 4 -
.../operators/s3.rst | 4 -
.../operators/s3_to_redshift.rst | 4 -
.../operators/salesforce_to_s3.rst | 4 -
.../operators/{ecs.rst => sqs_publish.rst} | 25 +-
.../commits.rst | 18 +-
.../index.rst | 2 +-
.../operators.rst | 4 -
.../operators.rst | 5 -
.../index.rst | 7 +
.../operators.rst | 25 +-
.../commits.rst | 18 +-
.../apache-airflow-providers-apache-hdfs/index.rst | 2 +-
.../operators.rst | 5 -
.../connections/spark.rst | 6 +-
.../operators.rst | 4 -
.../commits.rst | 21 +-
.../index.rst | 2 +-
.../operators.rst | 6 +-
.../commits.rst | 19 +-
docs/apache-airflow-providers-databricks/index.rst | 2 +-
docs/apache-airflow-providers-docker/commits.rst | 20 +-
docs/apache-airflow-providers-docker/index.rst | 2 +-
docs/apache-airflow-providers-google/commits.rst | 35 +-
.../example-dags.rst | 2 +-
docs/apache-airflow-providers-google/index.rst | 9 +-
.../operators/ads.rst | 4 -
.../operators/cloud/automl.rst | 7 -
.../operators/cloud/bigquery.rst | 4 -
.../operators/cloud/bigquery_dts.rst | 6 -
.../operators/cloud/bigtable.rst | 5 -
.../operators/cloud/cloud_build.rst | 5 -
.../operators/cloud/cloud_memorystore.rst | 4 -
.../cloud/cloud_memorystore_memcached.rst | 4 -
.../operators/cloud/cloud_sql.rst | 4 -
.../cloud/cloud_storage_transfer_service.rst | 4 -
.../operators/cloud/compute.rst | 4 -
.../operators/cloud/compute_ssh.rst | 4 -
.../operators/cloud/data_loss_prevention.rst | 4 -
.../operators/cloud/datacatalog.rst | 4 -
.../operators/cloud/dataflow.rst | 4 -
.../operators/cloud/datafusion.rst | 4 -
.../operators/cloud/dataprep.rst | 6 +-
.../operators/cloud/dataproc.rst | 4 -
.../operators/cloud/datastore.rst | 4 -
.../operators/cloud/functions.rst | 4 -
.../operators/cloud/gcs.rst | 4 -
.../operators/cloud/kubernetes_engine.rst | 4 -
.../operators/cloud/life_sciences.rst | 5 -
.../operators/cloud/mlengine.rst | 4 -
.../operators/cloud/natural_language.rst | 4 -
.../operators/cloud/pubsub.rst | 4 -
.../operators/cloud/spanner.rst | 4 -
.../operators/cloud/stackdriver.rst | 4 -
.../operators/cloud/translate.rst | 4 -
.../operators/cloud/translate_speech.rst | 4 -
.../operators/cloud/video_intelligence.rst | 4 -
.../operators/cloud/vision.rst | 4 -
.../operators/cloud/workflows.rst | 4 -
.../operators/firebase/firestore.rst | 4 -
.../operators/leveldb/leveldb.rst | 4 -
.../operators/marketing_platform/analytics.rst | 5 -
.../marketing_platform/campaign_manager.rst | 5 -
.../operators/marketing_platform/display_video.rst | 4 -
.../operators/marketing_platform/search_ads.rst | 4 -
.../operators/suite/sheets.rst | 5 -
.../operators/transfer/facebook_ads_to_gcs.rst | 4 -
.../operators/transfer/gcs_to_gdrive.rst | 5 -
.../operators/transfer/gcs_to_local.rst | 5 -
.../operators/transfer/gcs_to_sftp.rst | 5 -
.../operators/transfer/gcs_to_sheets.rst | 4 -
.../operators/transfer/gdrive_to_gcs.rst | 5 -
.../operators/transfer/gdrive_to_local.rst | 5 -
.../operators/transfer/local_to_gcs.rst | 5 -
.../operators/transfer/mysql_to_gcs.rst | 5 -
.../operators/transfer/oracle_to_gcs.rst | 5 -
.../operators/transfer/s3_to_gcs.rst | 4 -
.../operators/transfer/salesforce_to_gcs.rst | 4 -
.../operators/transfer/sftp_to_gcs.rst | 5 -
.../operators/transfer/sheets_to_gcs.rst | 4 -
.../operators/transfer/sql_to_sheets.rst | 4 -
.../google-cloud-secret-manager-backend.rst | 4 +-
.../apache-airflow-providers-hashicorp/commits.rst | 18 +-
docs/apache-airflow-providers-hashicorp/index.rst | 6 +-
docs/apache-airflow-providers-influxdb/commits.rst | 41 +
.../connections/influxdb.rst} | 39 +-
.../index.rst | 51 +-
.../installing-providers-from-sources.rst | 0
.../connections/jdbc.rst | 2 +-
docs/apache-airflow-providers-jdbc/operators.rst | 4 -
.../commits.rst | 26 +-
.../connections/adx.rst | 55 +-
.../connections/azure_batch.rst | 22 +-
.../index.rst | 14 +-
.../operators/adf_run_pipeline.rst | 4 -
.../operators/adls.rst | 11 +-
.../operators/azure_blob_to_gcs.rst | 6 +-
.../operators/local_to_adls.rst | 5 -
.../secrets-backends/azure-key-vault.rst | 7 +
docs/apache-airflow-providers-neo4j/commits.rst | 15 +-
docs/apache-airflow-providers-neo4j/index.rst | 2 +-
.../apache-airflow-providers-papermill/commits.rst | 17 +-
docs/apache-airflow-providers-papermill/index.rst | 2 +-
docs/apache-airflow-providers-postgres/commits.rst | 22 +-
docs/apache-airflow-providers-postgres/index.rst | 6 +-
docs/apache-airflow-providers-slack/commits.rst | 20 +-
docs/apache-airflow-providers-slack/index.rst | 12 +-
.../operators/slack_operator_howto_guide.rst | 44 +
.../apache-airflow-providers-snowflake/commits.rst | 19 +-
docs/apache-airflow-providers-snowflake/index.rst | 6 +-
docs/apache-airflow-providers-ssh/commits.rst | 18 +-
docs/apache-airflow-providers-ssh/index.rst | 2 +-
.../howto/create-update-providers.rst | 2 -
docs/apache-airflow-providers/index.rst | 5 +-
.../installing-from-pypi.rst | 3 -
.../installing-from-sources.rst | 5 +-
docs/apache-airflow/best-practices.rst | 6 +-
docs/apache-airflow/concepts/index.rst | 1 +
docs/apache-airflow/concepts/overview.rst | 2 +-
docs/apache-airflow/concepts/scheduler.rst | 5 +-
docs/apache-airflow/concepts/timetable.rst | 50 +
docs/apache-airflow/dag-run.rst | 2 +-
docs/apache-airflow/extra-packages-ref.rst | 2 +
docs/apache-airflow/howto/connection.rst | 8 +-
docs/apache-airflow/howto/customize-ui.rst | 4 +-
docs/apache-airflow/howto/email-config.rst | 19 +-
docs/apache-airflow/howto/set-up-database.rst | 10 +-
docs/apache-airflow/howto/timetable.rst | 47 +-
docs/apache-airflow/installation/index.rst | 2 +-
.../installation/installing-from-pypi.rst | 3 -
.../installation/installing-from-sources.rst | 3 -
.../logging-monitoring/logging-tasks.rst | 2 +-
docs/apache-airflow/security/access-control.rst | 4 -
docs/apache-airflow/security/api.rst | 4 -
docs/apache-airflow/security/flower.rst | 4 -
docs/apache-airflow/security/kerberos.rst | 4 -
docs/apache-airflow/security/webserver.rst | 4 -
docs/apache-airflow/security/workload.rst | 4 -
docs/apache-airflow/start/docker-compose.yaml | 11 +-
docs/apache-airflow/start/docker.rst | 36 +-
docs/apache-airflow/start/local.rst | 2 +-
docs/apache-airflow/templates-ref.rst | 16 +-
docs/apache-airflow/timezone.rst | 2 +-
docs/apache-airflow/tutorial_taskflow_api.rst | 15 +-
docs/apache-airflow/upgrading-from-1-10/index.rst | 2 -
.../upgrading-from-1-10/upgrade-check.rst | 2 -
docs/docker-stack/build-arg-ref.rst | 12 +-
docs/docker-stack/build.rst | 2 +-
docs/docker-stack/entrypoint.rst | 6 +-
docs/exts/docs_build/docs_builder.py | 3 +
.../exts/docs_build/helm_chart_utils.py | 22 +-
.../adding-connections-and-variables.rst | 10 +-
.../installing-helm-chart-from-sources.rst | 17 +-
docs/helm-chart/parameters-ref.rst | 4 -
docs/helm-chart/production-guide.rst | 56 +
docs/helm-chart/quick-start.rst | 2 +-
docs/installing-providers-from-sources.rst | 3 -
docs/publish_docs.py | 10 +-
docs/spelling_wordlist.txt | 4 +
images/quick_start/vscode_add_configuration_1.png | Bin 0 -> 86990 bytes
images/quick_start/vscode_add_configuration_2.png | Bin 0 -> 74910 bytes
images/quick_start/vscode_add_configuration_3.png | Bin 0 -> 90964 bytes
images/quick_start/vscode_add_env_variable.png | Bin 0 -> 69923 bytes
images/quick_start/vscode_click_on_clone.png | Bin 0 -> 49157 bytes
images/quick_start/vscode_clone.png | Bin 0 -> 43746 bytes
images/quick_start/vscode_creating_branch_1.png | Bin 0 -> 96114 bytes
images/quick_start/vscode_creating_branch_2.png | Bin 0 -> 7916 bytes
images/vscode_add_pytest_settings.png | Bin 0 -> 51247 bytes
images/vscode_configure_python_tests.png | Bin 0 -> 78770 bytes
images/vscode_install_python_extension.png | Bin 0 -> 119090 bytes
images/vscode_run_tests.png | Bin 0 -> 118344 bytes
images/vscode_select_pytest_framework.png | Bin 0 -> 72694 bytes
scripts/ci/docker-compose/_docker_compose.env | 49 +
.../docker-compose/backend-mssql-bind-volume.yml | 2 +-
.../docker-compose/backend-mssql-docker-volume.yml | 2 +-
scripts/ci/docker-compose/backend-mssql-port.yml | 2 +-
scripts/ci/docker-compose/backend-mssql.yml | 3 +-
scripts/ci/docker-compose/backend-mysql-port.yml | 2 +-
scripts/ci/docker-compose/backend-mysql.yml | 3 +-
.../ci/docker-compose/backend-postgres-port.yml | 2 +-
scripts/ci/docker-compose/backend-postgres.yml | 2 +-
scripts/ci/docker-compose/backend-sqlite-port.yml | 2 +-
scripts/ci/docker-compose/backend-sqlite.yml | 2 +-
scripts/ci/docker-compose/base.yml | 5 +-
scripts/ci/docker-compose/files.yml | 2 +-
scripts/ci/docker-compose/forward-credentials.yml | 2 +-
scripts/ci/docker-compose/ga.yml | 2 +-
.../ci/docker-compose/integration-cassandra.yml | 2 +-
scripts/ci/docker-compose/integration-kerberos.yml | 2 +-
scripts/ci/docker-compose/integration-mongo.yml | 2 +-
scripts/ci/docker-compose/integration-openldap.yml | 2 +-
scripts/ci/docker-compose/integration-pinot.yml | 2 +-
scripts/ci/docker-compose/integration-rabbitmq.yml | 2 +-
scripts/ci/docker-compose/integration-redis.yml | 2 +-
scripts/ci/docker-compose/integration-statsd.yml | 2 +-
scripts/ci/docker-compose/integration-trino.yml | 2 +-
scripts/ci/docker-compose/local-all-sources.yml | 2 +-
scripts/ci/docker-compose/local.yml | 2 +-
scripts/ci/docker-compose/remove-sources.yml | 2 +-
scripts/ci/images/ci_prepare_ci_image_on_ci.sh | 1 +
scripts/ci/images/ci_prepare_prod_image_on_ci.sh | 1 +
.../ci/images/ci_wait_for_and_verify_ci_image.sh | 2 +
.../ci/images/ci_wait_for_and_verify_prod_image.sh | 2 +
..._cluster_and_run_kubernetes_tests_single_job.sh | 7 +
..._cluster_with_different_executors_single_job.sh | 7 +
scripts/ci/libraries/_build_images.sh | 63 +-
scripts/ci/libraries/_md5sum.sh | 34 +-
scripts/ci/libraries/_parallel.sh | 2 +-
scripts/ci/libraries/_runs.sh | 5 +
.../pre_commit_check_order_dockerfile_extras.py | 33 +-
.../ci/pre_commit/pre_commit_check_order_setup.py | 26 +-
scripts/ci/pre_commit/pre_commit_ci_build.sh | 1 -
scripts/ci/pre_commit/pre_commit_flake8.sh | 2 -
scripts/ci/pre_commit/pre_commit_mypy.sh | 2 -
scripts/ci/testing/ci_run_airflow_testing.sh | 4 +-
.../ci_run_single_airflow_test_in_docker.sh | 62 +-
scripts/in_container/_in_container_utils.sh | 2 +
scripts/in_container/entrypoint_ci.sh | 4 +-
scripts/in_container/prod/entrypoint_prod.sh | 2 +-
setup.py | 19 +-
tests/api/client/test_local_client.py | 8 +-
.../endpoints/test_dag_run_endpoint.py | 33 +-
.../endpoints/test_task_instance_endpoint.py | 41 +
.../api_connexion/endpoints/test_user_endpoint.py | 59 +
tests/cli/commands/test_dag_command.py | 2 +
tests/cli/commands/test_user_command.py | 6 +-
tests/conftest.py | 3 +-
tests/core/test_configuration.py | 24 +
tests/core/test_core.py | 46 -
tests/core/test_impersonation_tests.py | 4 +-
tests/core/test_sentry.py | 28 +-
tests/deprecated_classes.py | 2 +-
tests/jobs/test_local_task_job.py | 2 +-
tests/jobs/test_scheduler_job.py | 52 +-
tests/models/test_baseoperator.py | 270 +--
tests/models/test_cleartasks.py | 2 +-
tests/models/test_dag.py | 95 +-
tests/models/test_dagbag.py | 9 +
tests/models/test_taskinstance.py | 20 +-
tests/operators/test_python.py | 18 +
tests/operators/test_trigger_dagrun.py | 51 +-
tests/providers/amazon/aws/hooks/test_eks.py | 90 +-
tests/providers/amazon/aws/hooks/test_glue.py | 3 +-
tests/providers/amazon/aws/hooks/test_s3.py | 19 +-
tests/providers/amazon/aws/operators/test_ecs.py | 39 +
tests/providers/amazon/aws/operators/test_glue.py | 2 +-
.../aws/operators/test_s3_list_prefixes.py} | 25 +-
tests/providers/amazon/aws/sensors/test_s3_key.py | 10 +
.../amazon/aws/utils/test_eks_get_token.py | 85 +
.../apache/cassandra/sensors/test_record.py | 10 +
.../apache/cassandra/sensors/test_table.py | 6 +
.../providers/apache/drill/operators/test_drill.py | 4 +-
tests/providers/docker/decorators/test_docker.py | 55 +-
.../providers/google/cloud/hooks/test_dataflow.py | 17 +-
.../google/cloud/hooks/test_natural_language.py | 2 +-
.../operators/test_cloud_build_system_helper.py | 2 +-
.../google/cloud/operators/test_dataflow.py | 18 +-
.../google/cloud/operators/test_dataprep_system.py | 4 +-
.../cloud/operators/test_datastore_system.py | 2 +-
.../cloud/operators/test_gcs_system_helper.py | 9 +-
.../google/cloud/sensors/test_datafusion.py | 30 +-
.../google/cloud/transfers/test_adls_to_gcs.py | 4 +-
.../{zendesk/hooks => influxdb}/__init__.py | 0
.../{zendesk => influxdb}/hooks/__init__.py | 0
tests/providers/influxdb/hooks/test_influxdb.py | 88 +
.../microsoft/azure/hooks/test_azure_batch.py | 23 +-
.../microsoft/azure/operators/test_adls_delete.py | 6 +-
.../microsoft/azure/operators/test_adls_list.py | 6 +-
.../microsoft/azure/operators/test_azure_batch.py | 23 +-
.../operators/test_azure_container_instances.py | 8 +-
.../azure/transfers/test_local_to_adls.py | 2 +-
.../providers/redis/sensors/test_redis_pub_sub.py | 8 +-
tests/providers/snowflake/hooks/test_snowflake.py | 6 +-
tests/providers/ssh/hooks/test_ssh.py | 12 +-
tests/providers/trino/hooks/test_trino.py | 18 +-
tests/sensors/test_external_task_sensor.py | 2 +
tests/test_utils/www.py | 2 +-
.../zendesk/hooks => timetables}/__init__.py | 0
tests/timetables/test_workday_timetable.py | 104 ++
.../www/api/experimental/test_dag_runs_endpoint.py | 4 +-
tests/www/views/test_views.py | 33 +
tests/www/views/test_views_dagrun.py | 10 +-
tests/www/views/test_views_home.py | 4 +-
tests/www/views/test_views_tasks.py | 63 +-
569 files changed, 8747 insertions(+), 3096 deletions(-)
copy airflow/{providers/telegram/example_dags/example_telegram.py =>
example_dags/example_time_delta_sensor_async.py} (56%)
copy airflow/example_dags/{tutorial_taskflow_api_etl_docker_virtualenv.py =>
tutorial_taskflow_api_etl_virtualenv.py} (78%)
create mode 100644 airflow/providers/alibaba/.latest-doc-only-change.txt
create mode 100644 airflow/providers/amazon/aws/example_dags/example_athena.py
create mode 100644 airflow/providers/amazon/aws/example_dags/example_sqs.py
copy airflow/providers/amazon/aws/operators/{s3_list.py =>
s3_list_prefixes.py} (73%)
create mode 100644 airflow/providers/amazon/aws/utils/eks_get_token.py
copy {tests/www/api/experimental =>
airflow/providers/apache/druid/example_dags}/__init__.py (100%)
copy airflow/providers/{slack/example_dags/example_slack.py =>
apache/druid/example_dags/example_druid_dag.py} (52%)
rename airflow/{ =>
providers/docker}/example_dags/tutorial_taskflow_api_etl_docker_virtualenv.py
(88%)
create mode 100644 airflow/providers/elasticsearch/.latest-doc-only-change.txt
copy docs/apache-airflow/concepts/index.rst =>
airflow/providers/influxdb/CHANGELOG.rst (58%)
copy {tests/providers/zendesk/hooks => airflow/providers/influxdb}/__init__.py
(100%)
copy {tests/providers/zendesk/hooks =>
airflow/providers/influxdb/example_dags}/__init__.py (100%)
create mode 100644 airflow/providers/influxdb/example_dags/example_influxdb.py
copy {tests/providers/zendesk => airflow/providers/influxdb}/hooks/__init__.py
(100%)
create mode 100644 airflow/providers/influxdb/hooks/influxdb.py
copy airflow/providers/{papermill => influxdb}/provider.yaml (62%)
copy airflow/providers/microsoft/azure/operators/{adls_delete.py => adls.py}
(60%)
copy airflow/{www/templates/airflow/conn_create.html =>
providers/sqlite/example_dags/create_table.sql} (66%)
copy {tests/providers/zendesk/hooks => airflow/www/fab_security}/__init__.py
(100%)
create mode 100644 airflow/www/fab_security/manager.py
copy {tests/providers/zendesk/hooks =>
airflow/www/fab_security/sqla}/__init__.py (100%)
create mode 100644 airflow/www/fab_security/sqla/manager.py
copy airflow/www/templates/airflow/{conn_create.html => _messages.html} (66%)
create mode 100644
chart/templates/rbac/security-context-constraint-rolebinding.yaml
create mode 100644 chart/tests/test_scc_rolebinding.py
copy docs/apache-airflow-providers-amazon/operators/{ecs.rst => athena.rst}
(58%)
copy docs/apache-airflow-providers-amazon/operators/{ecs.rst =>
sqs_publish.rst} (65%)
copy docs/{apache-airflow-providers-apache-drill =>
apache-airflow-providers-apache-druid}/operators.rst (51%)
create mode 100644 docs/apache-airflow-providers-influxdb/commits.rst
copy docs/{apache-airflow-providers-jdbc/connections/jdbc.rst =>
apache-airflow-providers-influxdb/connections/influxdb.rst} (52%)
copy docs/{apache-airflow-providers-neo4j =>
apache-airflow-providers-influxdb}/index.rst (61%)
copy docs/{apache-airflow-providers-zendesk =>
apache-airflow-providers-influxdb}/installing-providers-from-sources.rst (100%)
create mode 100644
docs/apache-airflow-providers-slack/operators/slack_operator_howto_guide.rst
create mode 100644 docs/apache-airflow/concepts/timetable.rst
copy scripts/ci/docker-compose/backend-mssql-port.yml =>
docs/exts/docs_build/helm_chart_utils.py (68%)
create mode 100644 images/quick_start/vscode_add_configuration_1.png
create mode 100644 images/quick_start/vscode_add_configuration_2.png
create mode 100644 images/quick_start/vscode_add_configuration_3.png
create mode 100644 images/quick_start/vscode_add_env_variable.png
create mode 100644 images/quick_start/vscode_click_on_clone.png
create mode 100644 images/quick_start/vscode_clone.png
create mode 100644 images/quick_start/vscode_creating_branch_1.png
create mode 100644 images/quick_start/vscode_creating_branch_2.png
create mode 100755 images/vscode_add_pytest_settings.png
create mode 100755 images/vscode_configure_python_tests.png
create mode 100755 images/vscode_install_python_extension.png
create mode 100755 images/vscode_run_tests.png
create mode 100755 images/vscode_select_pytest_framework.png
create mode 100644 scripts/ci/docker-compose/_docker_compose.env
copy tests/providers/{microsoft/azure/operators/test_adls_delete.py =>
amazon/aws/operators/test_s3_list_prefixes.py} (53%)
create mode 100644 tests/providers/amazon/aws/utils/test_eks_get_token.py
copy tests/providers/{zendesk/hooks => influxdb}/__init__.py (100%)
copy tests/providers/{zendesk => influxdb}/hooks/__init__.py (100%)
create mode 100644 tests/providers/influxdb/hooks/test_influxdb.py
copy tests/{providers/zendesk/hooks => timetables}/__init__.py (100%)
create mode 100644 tests/timetables/test_workday_timetable.py
