You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by je...@apache.org on 2022/02/18 13:15:27 UTC
[airflow] branch v2-2-stable updated (06c82e1 -> ee9049c)
This is an automated email from the ASF dual-hosted git repository.
jedcunningham pushed a change to branch v2-2-stable
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from 06c82e1 Add changelog for 2.2.3rc2
add 027e1d1 Bump version to 2.2.4
add fd5558f Fixing ses email backend (#18042)
add d2ae684 Enhance `multiple_outputs` inference of dict typing (#19608)
add b05722e Correctly send timing metrics when using dogstatsd (fix schedule_delay metric) (#19973)
add 03be5a1 Update upgrading.rst with detailed code example of how to resolve post-upgrade warning (#19993)
add 94865f9 Adds retry on taskinstance retrieval lock (#20030)
add 1285215 Docs for multiple pool slots (#20257)
add c7256dc Doc: Fix incorrect filename references (#20277)
add d6466ee fix(dag-dependencies): fix arrow styling (#20303)
add 1a7f943 Add docs about ``.airflowignore`` (#20311)
add 614cd3c Fix typo (#20314)
add c836e71 Bugfix: Deepcopying Kubernetes Secrets attributes causing issues (#20318)
add a25d7ce Un-ignore DeprecationWarning (#20322)
add 2ee6351 Fix grammar mistakes (#20341)
add f1a2e50 Correct typo (#20345)
add 581fcfd Remove unnecssary logging in experimental API (#20356)
add 330c365 Fix typo in docs (#20371)
add b19dfdb fix(standalone): Remove hardcoded Webserver port (#20429)
add b43882c Avoid calling DAG.following_schedule() for TaskInstance.get_template_context() (#20486)
add 3692007 20496 fix port standalone mode (#20505)
add cb6891b Doc: Update Supported column for 1.10.x series (#20592)
add 9912cf1 Docs: Changed macros to correct classes and modules (#20637)
add 713a807 Docs: Clarify ``sentry_on`` value is not quoted with example (#20639)
add 97d90c1 breeze setup-autocomplete zshrc reload (#18893)
add 01edc7e Workaround docker-compose-v2 env passing (#18887)
add ef817be Fix comparision of docker versions (#18902)
add 49e582a Remove adding of "test-run" variables to dc_ci script (#18903)
add 40bf532 Decrease likelihood of memory issue in CI (#18852)
add ebf1ff7 Fix typos ``build.rst`` (#18935)
add 56aa22e Fix --github-image-id flag for Breeze (#18882) (#18946)
add 31eea57 Add decription on how you can customize image entrypoint (#18915)
add ecdadf5 CI: Increase parallel test timeout for Helm Chart tests (#18993)
add 7b1fb7e Skip updating constraints when only datetime changes (#19023)
add dd1a3fa Fix wrong commands in docs/breeze
add c8f492b Allow specifying extras when using breeze initialize_local_virtualenv (#19178)
add 80f4e5f Fix breeze docker version parsing (#19182)
add d5ee471 pyenv related docs added, warning message in breeze initialize-local-virtualenv command (#19100)
add 6f6e9c2 Skip triggerer in 'breeze start-airflow' if on 3.6 (#19305)
add 70c5869 Temporarily remove mypy checks to stop PRs from failing (#19345)
add e166a37 Enable mouse mode by default in start_airflow tmux session (#19325)
add cfa1bae Make scripts/in_container/check_environment.sh Google Shell Guide Compliant (#19350)
add 581e974 Fix --disable-mssql-client-installation error (#19295)
add 74cba25 Updates version of airflow in docker examples (#19455)
add 9f0271b Fix docker "after entrypoint" custom script example (#19495)
add 7f41a04 Optimizes running tests for public GitHub Runners. (#19512)
add 94b923d Disable test code coverage for PRs (#19523)
add 75dc1c0 Upload KinD logs on cancell too (#19554)
add 68f729c Stop polling when Webserver doesn't start up in Kube tests (#19598)
add e8a8566 Improve automation for docker image release (#19573)
add 97c0069 Move scripts for prod image preparation to dev (#19623)
add 82964ef Disable yarn-dev in start-airflow command (#19626)
add 4b09fac Fix failing CI phase with unhealthy container issue (#19633)
add 6561e7b Clean up dynamic `start_date` values from docs (#19607)
add 6aacc66 Misc. documentation typos and language improvements (#19599)
add 319d327 Fix dumping container logs on error (#19645)
add cd55810 Add more complete instruction for reproducing failed integration tests (#19646)
add 8a79d7e Fix CI tests so they correctly fail in case of error! (#19678)
add 3276864 Fix speed of yarn installation (#19697)
add 84c523d Speed up webserver start up in Kube tests (#19710)
add 01de1b7 Remove duplicate line call in CI (#19728)
add 8712710 Lower the recommended disk space requirements (#19775)
add 500946a Run Other tests sequentially for Public GitHub runners (#19766)
add da2f943 Add option to run PRs on public runners by maintainers. (#19772)
add c931b9c Sync committers in ci config for self-hosted runners (#19786)
add 069158e Add note to restart runners when updating committers (#19795)
add f9c444c Tests for Docker images in Python (#19737)
add 92b8ac3 Upload provider distribution artifacts during CI (#19807)
add 2e37124 Fixes failure of image building (#19813)
add 85cdc4d Bring back Core and Other tests to be run in parallel (#19812)
add 3a878d5 Fix PATH export in breeze tmux sessions (#19818)
add 66ae46c Use hyphen instead of underscore to match other artifacts (#19820)
add 7e01977 Rewrite image building tests to Python (#19819)
add ab752e7 Fix race condition when running mssql tests (#19863)
add 601d00c Add tests for docker-compose quick start (#19874)
add f9ff33f Remove the docker timeout workaround (#18872)
add 1a80dcd Add ``semver`` to devel deps (#18818)
add 60e2b65 Add pandas requirements for providers that use pandas (#18997)
add a5ee60e Upgrade the Dataproc package to 3.0.0 and migrate from v1beta2 to v1 api (#18879)
add 2ad02ef Add dataproc metastore operators (#18945)
add 44f5dc5 Add hdfs requirement for hdfs provider (#19540)
add e2dcdfd Fix failures with recent moto library 2.2.15 (#19693)
add 67fc1d7 Create dataproc serverless spark batches operator (#19248)
add 95b9d48 Move to watchtower 2.0.1 (#19907)
add 85cce07 Fix ``breeze kind-cluster shell`` (#20015)
add 5f1236f update upper bound for MarkupSafe (#19953)
add f1c7f06 switch to follow_redirects on httpx.get call in CloudSQL provider (#20239)
add 7250d89 Lift off upper bound for MarkupSafe (#20113)
add 27fbbea Upload provider artifacts before install/test step (#20137)
add 96f88a6 Update Sphinx and Sphinx-AutoAPI (#20079)
add d761aff Update minimum sphinx versions after upgrading sphinx-autoapi (#20170)
add 689ded0 Increase limit of time for constraint job (#20230)
add 989e73c Remove Integration tests from MSSQL on Public Runners (#20231)
add 4c60fb2 YandexCloud provider: Support new Yandex SDK features: log_group_id, user-agent, maven packages (#20103)
add ac6b016 Speed up Helm Upgrade tests (#20289)
add 09602fc Fix race condition when flake checks run in parallel (#20294)
add 53d73dc Change default python version in docker image docs (#20389)
add 793aaa9 Limit Snowflake connector to< 2.7.2 (#20395)
add 2dbbe2b Add pre-commit that checks credentials are not persisted in CI (#20430)
add 48f39d1 Add custom pip.conf to docker-context-files (#20445)
add 0746bc8 Checks if the user running Breeze has permissions to run docker cmd (#20462)
add ef319b0 Add autoflake precommit to automatically remove unused code (#20466)
add 58a65e1 Bump PyJWT from `<2` to `<3` (#20490)
add 933716b Fix: pin pymongo < 4.0.0 (#20511)
add 0df0dcd Increase time limit for Helm chart unit tests (#20525)
add 95e71b7 Remove PyJWT upper bound from Dockerfile (#20503)
add bccf2f5 Bump croniter from `<1.1` to `<1.2` (#20489)
add e294620 Update "Release Airflow" doc (#19111)
add 59a6aca Dev: Clarify file naming in release verification doc (#19233)
add 23b2e7b Fix release check script (#19238)
add 35b5cd2 Clarify rat test guidance in release check docs (#19296)
add ae18469 Update known warnings for Python 3.7 (#19333)
add 734ab55 Clarify guidance re trust of keys in release docs (#19480)
add ae28789 Update description of release process for adding new major release (#19483)
add 8a66731 Update helm chart release docs (#19494)
add 3f41c95 Clarify that .asf.yml and codecov.yml should be changed in main (#19496)
add 04b380b Add script to generate issue for status of testing of the rc (#19247)
add b2c9085 Add script to generate chart changelog annotations (#20555)
add c92409c Update docs about releasing providersk (#19549)
add c7236c7 Fix failing CI phase with unhealthy container issue (#19633)
add 371ae8f Fix dumping container logs on error (#19645)
add a5ad8bb Update Airflow release guide (#19663)
add 40283e3 Fix CI tests so they correctly fail in case of error! (#19678)
add 84082d3 Add retagging images accross repos (#19778)
add 3af9ffd Upload provider distribution artifacts during CI (#19807)
add dfde1ba Bring back Core and Other tests to be run in parallel (#19812)
add b96093d Fix OOM error in tests when using public Github Runners. (#19809)
add 5917719 Update docs/tools for releasing core Airflow (#20211)
add 3162de5 Fix MyPy errors in `dev/*` (#20261)
add 3087dd2 Fix MyPy errors in `scripts/in_container` (#20280)
add b43fb3d Only list linked issues once in release issues (#20299)
add 92ef164 Add exiting on error in prod image script (#20447)
add ec08a5c Add possibility to ignore common deprecated message (#20444)
add ce55c30 Update the "releasing Airflow" docs (#20456)
add e02aa46 Generate version documentation from single source of truth (#20594)
add 8443c73 Add known warning generated by snowflake new version (#20604)
add 8a432bb Add twine check for provider packages (#20619)
add 3c3f246 Fix generation of "Status provider" issue (#20621)
add dfc4968 Generate constraints in PRs when upgrading dependencies (#20624)
add f19a89c Fix Constraints failure in PRs (#20631)
add e21fc84 upgrade celery 5.2.3 (#19703)
add bedf40c Bump flask-appbuilder to >=3.3.4 (#20628)
add f8bb2c2 Fix incorrect arguments (#20638)
add f05725e Cleaner output of docker image building scripts (#20679)
add a2fb0f4 Be build -> built, and a stray space (#20703)
add 2c7cea7 Fix naming convention for sdist provider packages (#20711)
add 907d107 Add color to pytest tests on CI (#20723)
add a4c57e5 Modernize usage of PIP in Airflow images (#20726)
add 172e536 Uses airflow user for build segment of docker image (#20744)
add 0cd9904 Cleaner output for Docker image building (#20747)
add 9b5e913 Optimize dockerfiles for local rebuilds (#20238)
add 33e3622 Unpin ``cattrs`` (#20872)
add eeeacc4 Unpin ``argcomplete`` and ``colorlog`` (#20878)
add 2abcd4f add entry in release readme to update milestone in Issues (#20890)
add ef0a980 Switch to new MySQL public key (#20912)
add bf7a755 Uses CI images built in previous step to prepare PROD image (#20889)
add c5082cb Switch to non-vendored latest connexion library (#20910)
add e36c54f Fix errors thrown by some versions of Bash v4 (#20932)
add 5ccbf30 Switch to 'buildkit' to build Airflow images (#20664)
add f466f1c Fix new buildkit builds on MacOS (#20963)
add fa83fa4 Update base python image to be Python 3.7 by default (#20978)
add 9d5c403 Add extra sync when adding executable flag to installation scripts (#20987)
add bf0dd93 Get rid of upload coverage warnings (#20994)
add 0f868a8 Update refreshing constraints instructions (#21001)
add 676e160 Update md5 information about image after waiting (#21000)
add d4660a8 Update Celery requirements
add 6f4d29c Add roles to create_user test (#20773)
add 3fa1535 Fix failing main. (#20094)
add ad00e8e Restore stability and unquarantine all test_scheduler_job tests (#19860)
add 83a4090 Fix occasional external task sensor tests (#18853)
add ab50aa7 Hide version selector for non-versioned packages (#21041)
add 9e34741 Adds back documentation about context usage in Python/@task (#18868)
add c3ead66 Updating explicit arg example in TaskFlow API tutorial doc (#18907)
add 97a7fe7 Adds Pendulum 1.x -> 2.x upgrade documentation (#18955)
add cc7f80d Update CSV ingest code for tutorial (#18960)
add 1463777 Add docker-compose explanation to conn localhost (#19076)
add 67b5f88 Doc: Improve tutorial documentation and code (#19186)
add 80d1b68 docs: reorder imports in tutorials 🎨 (#19035)
add 612e5c5 Fix PostgresHook import in tutorial (#19374)
add 8873abc Change the name of link to ASF downloads (#19441)
add 0072200 Clean up ``default_args`` usage in docs (#19803)
add 2ff09c3 Fix example code in Doc (#19824)
add 9a1c6b2 Add requirements.txt description (#20048)
add d8fe499 Correct set-up-database.rst (#20090)
add 7dfc7c1 Fix typo in MySQL Database creation code (Set up DB docs) (#20102)
add 52241bf Fix grammar and typos in "Logging for Tasks" guide (#20146)
add 25d7bbe Deprecate smart sensors (#20151)
add 50f4f9e Removes unnecessary --upgrade option from our examples (#20537)
add e43138f Improve documentation on ``Params`` (#20567)
add 915054f Update operators.rst (#20640)
add 88d1da8 Compare taskgroup and subdag (#20700)
add 08ddaea Update metric name in documentation (#20764)
add 8b199eb Python3 requisite start local (#20777)
add d0a9f9a Doc: Added an enum param example (#20841)
add 06828d6 Fix grammar in ``dags.rst`` (#20988)
add cf90511 Add image labels required by ArtifactHub (#21040)
add 72085cc Update tutorial.rst (#21043)
add a262d9c Temporary limit Pandas version (#21045)
add a889305 Fix running airflow dags test <dag_id> <execution_dt> results in error when run twice (#21031)
add b1862ca Add a link to the DAG model in the Python API reference (#21060)
add cc9a034 Logs in to Github Registry when preparing cache (#21069)
add f99f7df Add documentation and release policy on "latest" constraints (#21093)
add fab8b12 Allow Viewing DagRuns and TIs if a user has DAG "read" perms (#20663)
add a9c178e Add Roles from Azure OAUTH Response in security manager as it is currently not able map any AD roles to airflow ones (#20707)
add 31c66eb Update v1.yaml (#21024)
add a670f8c name mismatch (#21055)
add 9f6d6b9 Update logging-tasks.rst (#21088)
add 680c011 Add back legacy .piprc customization for pip (#21124)
add 5b51c41 Improved instructions for custom image build with docker compose (#21052)
add 9f7d292 Update `version_added` for `[email] from_email` (#21138)
add 07102e9 Do not set `TaskInstance.max_tries` in `refresh_from_task` (#21018)
add dda8f43 Fix 'airflow dags backfill --reset-dagruns' errors when run twice (#21062)
add 016929f Type-annotate SkipMixin and BaseXCom (#20011)
add dda864d Helper for provide_session-decorated functions (#20104)
add daebc58 Fix session usage in ``/rendered-k8s`` view (#21006)
add 663bb54 Deprecate some functions in the experimental API (#19931)
add 4dc8b90 Avoid unintentional data loss when deleting DAGs (#20758)
add 6d8342e Removed duplicated dag_run join in Dag.get_task_instances() (#20591)
add 55a4abb bugfix: deferred tasks does not cancel when DAG is marked fail (#20649)
add 0ba033d Actually fix tuple and bool checks for black 22.1.0 (#21221)
add 1b139a7 Fix Scheduler crash when executing task instances of missing DAG (#20349)
add 4ff0ab1 Limit SQLAlchemy to < 1.4.0 for 2.2.* line (#21235)
add ede6d8f fןס Broken link in api.rst (#21165)
add 2066812 Update version to 2.2.4 for things in that release (#21196)
add 8890087 Augment xcom docs (#20755)
add 4b3fa3a Update recipe for Google Cloud SDK (#21268)
add a519e53 Docs: Fix task order in overview example (#21282)
add 015c481 Update stat_name_handler documentation (#21298)
add 64e0c50 Fix the incorrect scheduling time for the first run of dag (#21011)
add 270516c Update error docs to include before_send option (#21275)
add 5c078cd Update example DAGs (#21372)
add f41ea34 Fix docs link for smart sensor deprecation (#21394)
add f2fe0df Avoid deadlock when rescheduling task (#21362)
add 9b03071 Add possibility to create user in the Remote User mode (#19963)
add 95eaef3 Fix TriggerDagRunOperator extra link (#19410)
add 1c23405 Fix mismatch in generated run_id and logical date of DAG run (#18707)
add efc2818 Fix postgres hook import pipeline tutorial (#21491)
add 79e9954 Use compat data interval shim in log handlers (#21289)
add f25a58e Show task status only for running dags or only for the last finished dag (#21352)
add 1c2909f Add a session backend to store session data in the database (#21478)
add 628aa1f Simplify trigger cancel button (#21591)
add dd0a3a3 update tutorial_etl_dag notes (#21503)
add 436f452 Fix slow DAG deletion due to missing ``dag_id`` index for job table (#20282)
add 1cbad37 Reorder migrations to include bugfix in 2.2.4 (#21598)
add 7e80127 Add note about Variable precedence with env vars (#21568)
add 8cbf934 Adding missing login provider related methods from Flask-Appbuilder (#21294)
add 56d82fc added explaining concept of logical date in DAG run docs (#21433)
add 969a275 Clarify pendulum use in timezone cases (#21646)
add eb87aeb Add changelog for 2.2.4rc1
add 01b909b Pin Markupsafe until we are able to upgrade Flask/Jinja (#21664)
add ee9049c fixup! Add changelog for 2.2.4rc1
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 5 +-
.github/boring-cyborg.yml | 2 +-
.github/workflows/build-images.yml | 15 +-
.github/workflows/ci.yml | 182 +++-
.pre-commit-config.yaml | 23 +-
BREEZE.rst | 221 ++--
CHANGELOG.txt | 75 ++
CI.rst | 18 +-
CONTRIBUTING.rst | 2 +-
CONTRIBUTORS_QUICK_START.rst | 6 +-
Dockerfile | 359 ++++---
Dockerfile.ci | 169 ++--
IMAGES.rst | 176 +---
INSTALL | 4 +-
LOCAL_VIRTUALENV.rst | 7 +
PULL_REQUEST_WORKFLOW.rst | 12 +-
README.md | 31 +-
STATIC_CODE_CHECKS.rst | 6 +
UPDATING.md | 19 +-
airflow/_vendor/connexion/__init__.py | 48 -
airflow/_vendor/connexion/__main__.py | 3 -
airflow/_vendor/connexion/apis/__init__.py | 1 -
airflow/_vendor/connexion/apis/abstract.py | 446 --------
airflow/_vendor/connexion/apis/aiohttp_api.py | 394 --------
airflow/_vendor/connexion/apis/flask_api.py | 310 ------
airflow/_vendor/connexion/apis/flask_utils.py | 81 --
airflow/_vendor/connexion/apps/__init__.py | 1 -
airflow/_vendor/connexion/apps/abstract.py | 249 -----
airflow/_vendor/connexion/apps/aiohttp_app.py | 95 --
airflow/_vendor/connexion/apps/flask_app.py | 138 ---
airflow/_vendor/connexion/cli.py | 210 ----
airflow/_vendor/connexion/decorators/__init__.py | 0
.../connexion/decorators/coroutine_wrappers.py | 53 -
airflow/_vendor/connexion/decorators/decorator.py | 51 -
airflow/_vendor/connexion/decorators/metrics.py | 54 -
airflow/_vendor/connexion/decorators/parameter.py | 123 ---
airflow/_vendor/connexion/decorators/produces.py | 49 -
airflow/_vendor/connexion/decorators/response.py | 112 --
airflow/_vendor/connexion/decorators/security.py | 341 -------
.../_vendor/connexion/decorators/uri_parsing.py | 329 ------
airflow/_vendor/connexion/decorators/validation.py | 386 -------
airflow/_vendor/connexion/exceptions.py | 142 ---
airflow/_vendor/connexion/handlers.py | 85 --
airflow/_vendor/connexion/http_facts.py | 15 -
airflow/_vendor/connexion/json_schema.py | 114 ---
airflow/_vendor/connexion/jsonifier.py | 57 --
airflow/_vendor/connexion/lifecycle.py | 41 -
airflow/_vendor/connexion/mock.py | 47 -
airflow/_vendor/connexion/operations/__init__.py | 8 -
airflow/_vendor/connexion/operations/abstract.py | 445 --------
airflow/_vendor/connexion/operations/compat.py | 3 -
airflow/_vendor/connexion/operations/openapi.py | 380 -------
airflow/_vendor/connexion/operations/secure.py | 164 ---
airflow/_vendor/connexion/operations/swagger2.py | 310 ------
airflow/_vendor/connexion/options.py | 144 ---
airflow/_vendor/connexion/problem.py | 42 -
airflow/_vendor/connexion/resolver.py | 192 ----
airflow/_vendor/connexion/setup.cfg | 7 -
airflow/_vendor/connexion/setup.py | 119 ---
airflow/_vendor/connexion/spec.py | 262 -----
airflow/_vendor/connexion/utils.py | 250 -----
airflow/api/client/local_client.py | 29 +-
.../api/common/{experimental => }/delete_dag.py | 21 +-
airflow/api/common/experimental/delete_dag.py | 70 +-
airflow/api/common/experimental/get_code.py | 3 +
.../api/common/experimental/get_dag_run_state.py | 3 +
airflow/api/common/experimental/get_task.py | 3 +
.../api/common/experimental/get_task_instance.py | 3 +
airflow/api/common/experimental/mark_tasks.py | 121 ++-
airflow/api/common/experimental/pool.py | 6 +
airflow/api/common/experimental/trigger_dag.py | 115 +--
.../api/common/{experimental => }/trigger_dag.py | 5 +-
.../api_connexion/endpoints/connection_endpoint.py | 2 +-
airflow/api_connexion/endpoints/dag_endpoint.py | 9 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 2 +-
.../endpoints/role_and_permission_endpoint.py | 2 +-
airflow/api_connexion/endpoints/user_endpoint.py | 2 +
airflow/api_connexion/exceptions.py | 2 +-
airflow/api_connexion/openapi/v1.yaml | 2 -
airflow/cli/commands/dag_command.py | 6 +-
airflow/cli/commands/standalone_command.py | 10 +-
airflow/config_templates/config.yml | 15 +
airflow/config_templates/default_airflow.cfg | 9 +
airflow/dag_processing/manager.py | 2 +-
airflow/decorators/base.py | 27 +-
airflow/decorators/python.py | 16 +-
airflow/decorators/python_virtualenv.py | 10 +-
airflow/example_dags/example_bash_operator.py | 8 +-
.../example_branch_datetime_operator.py | 14 +-
.../example_branch_day_of_week_operator.py | 4 +-
airflow/example_dags/example_branch_labels.py | 7 +-
airflow/example_dags/example_branch_operator.py | 5 +-
.../example_branch_python_dop_operator_3.py | 4 +-
airflow/example_dags/example_complex.py | 4 +-
airflow/example_dags/example_dag_decorator.py | 9 +-
.../example_external_task_marker_dag.py | 4 +-
.../example_dags/example_kubernetes_executor.py | 5 +-
.../example_latest_only_with_trigger.py | 8 +-
airflow/example_dags/example_nested_branch_dag.py | 4 +-
.../example_passing_params_via_test_command.py | 19 +-
airflow/example_dags/example_python_operator.py | 5 +-
.../example_dags/example_short_circuit_operator.py | 4 +-
airflow/example_dags/example_skip_dag.py | 9 +-
airflow/example_dags/example_sla_dag.py | 8 +-
airflow/example_dags/example_subdag_operator.py | 14 +-
airflow/example_dags/example_task_group.py | 7 +-
.../example_dags/example_task_group_decorator.py | 7 +-
.../example_time_delta_sensor_async.py | 8 +-
.../example_dags/example_trigger_controller_dag.py | 4 +-
airflow/example_dags/example_trigger_target_dag.py | 4 +-
airflow/example_dags/example_xcom.py | 4 +-
airflow/example_dags/example_xcomargs.py | 7 +-
airflow/example_dags/subdags/subdag.py | 4 +-
airflow/example_dags/tutorial.py | 53 +-
airflow/example_dags/tutorial_etl_dag.py | 23 +-
airflow/example_dags/tutorial_taskflow_api_etl.py | 10 +-
airflow/exceptions.py | 4 +-
airflow/hooks/dbapi.py | 2 +-
airflow/jobs/base_job.py | 1 +
airflow/jobs/scheduler_job.py | 23 +
airflow/kubernetes/pod.py | 2 +-
airflow/kubernetes/pod_launcher.py | 4 +-
airflow/kubernetes/pod_runtime_info_env.py | 4 +-
.../dags_in_volume_template.yaml | 2 +-
airflow/kubernetes/secret.py | 16 +-
airflow/kubernetes/volume.py | 5 +-
airflow/kubernetes/volume_mount.py | 5 +-
.../2c6edca13270_resource_based_permissions.py | 1 -
...587bdf053233_adding_index_for_dag_id_in_job.py} | 34 +-
...ad25_resource_based_permissions_for_default_.py | 1 -
.../c381b21cb7e4_add_session_table_to_db.py | 52 +-
airflow/models/dag.py | 7 +-
airflow/models/pool.py | 52 +-
airflow/models/skipmixin.py | 15 +-
airflow/models/taskinstance.py | 90 +-
airflow/models/xcom.py | 343 ++++---
airflow/operators/datetime.py | 2 +-
airflow/operators/generic_transfer.py | 2 +-
airflow/operators/python.py | 26 +-
airflow/operators/trigger_dagrun.py | 41 +-
airflow/operators/weekday.py | 2 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 2 +-
airflow/providers/amazon/aws/utils/emailer.py | 3 +-
airflow/providers/docker/operators/docker_swarm.py | 7 -
.../providers/elasticsearch/log/es_task_handler.py | 27 +-
.../google/cloud/example_dags/example_dataproc.py | 10 +-
.../example_dags/example_dataproc_metastore.py | 216 ++++
.../google/cloud/example_dags/example_functions.py | 2 +-
airflow/providers/google/cloud/hooks/cloud_sql.py | 10 +-
airflow/providers/google/cloud/hooks/dataproc.py | 221 +++-
.../google/cloud/hooks/dataproc_metastore.py | 676 +++++++++++++
airflow/providers/google/cloud/hooks/workflows.py | 4 +-
.../providers/google/cloud/operators/dataproc.py | 338 ++++++-
.../google/cloud/operators/dataproc_metastore.py | 1068 ++++++++++++++++++++
.../providers/google/cloud/operators/workflows.py | 4 +-
airflow/providers/google/cloud/sensors/dataproc.py | 2 +-
.../google/cloud/utils/credentials_provider.py | 10 +-
.../cloud/utils/mlengine_prediction_summary.py | 4 +
.../google/common/utils/id_token_credentials.py | 4 +
airflow/providers/google/provider.yaml | 11 +
airflow/providers/http/operators/http.py | 10 +-
airflow/providers/http/sensors/http.py | 7 +-
airflow/providers/postgres/hooks/postgres.py | 4 +-
airflow/providers/sqlite/hooks/sqlite.py | 2 +-
.../example_dags/example_yandexcloud_dataproc.py | 12 +-
airflow/providers/yandex/hooks/yandex.py | 16 +-
.../yandex/operators/yandexcloud_dataproc.py | 40 +
airflow/sensors/base.py | 26 +-
airflow/sensors/external_task.py | 24 +-
airflow/sensors/weekday.py | 2 +-
airflow/serialization/serialized_objects.py | 6 +-
airflow/settings.py | 10 +-
airflow/smart_sensor_dags/smart_sensor_group.py | 10 +-
airflow/stats.py | 9 +-
airflow/timetables/base.py | 1 -
airflow/timetables/interval.py | 2 +-
airflow/utils/context.py | 33 +
airflow/utils/context.pyi | 6 +-
airflow/utils/db.py | 20 +-
airflow/utils/email.py | 10 +-
airflow/utils/helpers.py | 2 +-
airflow/utils/log/file_task_handler.py | 35 +-
.../log/task_handler_with_custom_formatter.py | 4 +-
airflow/utils/operator_helpers.py | 84 +-
airflow/utils/session.py | 11 +-
airflow/www/api/experimental/endpoints.py | 8 +-
airflow/www/app.py | 3 +-
airflow/www/ask_for_recompile_assets_if_needed.sh | 19 +-
airflow/www/decorators.py | 1 -
airflow/www/extensions/init_session.py | 63 +-
airflow/www/extensions/init_views.py | 5 +-
airflow/www/fab_security/manager.py | 16 +
.../www/{extensions/init_session.py => session.py} | 29 +-
airflow/www/static/js/dag_dependencies.js | 5 +-
airflow/www/templates/airflow/trigger.html | 2 +-
airflow/www/views.py | 125 ++-
breeze | 215 ++--
breeze-complete | 9 +-
dev/ISSUE_TEMPLATE.md.jinja2 | 21 +
dev/README_RELEASE_AIRFLOW.md | 398 ++++++--
dev/README_RELEASE_AIRFLOW_UPGRADE_CHECK.md | 37 +-
dev/README_RELEASE_HELM_CHART.md | 147 ++-
dev/README_RELEASE_PROVIDER_PACKAGES.md | 80 +-
dev/REFRESHING_CI_CACHE.md | 7 +-
dev/airflow-github | 9 +-
dev/airflow-license | 2 +-
dev/chart/build_changelog_annotations.py | 108 ++
dev/check_files.py | 159 ++-
dev/import_all_classes.py | 4 +-
.../ci/tools => dev}/prepare_prod_docker_images.sh | 35 +-
dev/prepare_release_issue.py | 298 ++++++
.../PROVIDER_ISSUE_TEMPLATE.md.jinja2 | 15 +-
dev/provider_packages/prepare_provider_packages.py | 216 +++-
dev/refresh_images.sh | 7 +-
dev/retag_docker_images.py | 33 +-
dev/validate_version_added_fields_in_config.py | 8 +-
{tests/timetables => docker_tests}/__init__.py | 0
.../get_code.py => docker_tests/command_utils.py | 32 +-
.../task/__init__.py => docker_tests/constants.py | 5 +-
docker_tests/docker_tests_utils.py | 100 ++
.../volume.py => docker_tests/test_ci_image.py | 32 +-
docker_tests/test_docker_compose_quick_start.py | 161 +++
.../test_examples_of_prod_image_building.py | 64 ++
docker_tests/test_prod_image.py | 211 ++++
.../index.rst | 1 -
docs/apache-airflow-providers-google/index.rst | 2 +-
.../operators/cloud/dataproc.rst | 1 -
.../operators/cloud/dataproc_metastore.rst | 196 ++++
docs/apache-airflow/best-practices.rst | 21 +-
docs/apache-airflow/concepts/dags.rst | 151 ++-
docs/apache-airflow/concepts/deferring.rst | 3 +-
docs/apache-airflow/concepts/operators.rst | 17 +-
docs/apache-airflow/concepts/overview.rst | 4 +-
docs/apache-airflow/concepts/params.rst | 152 ++-
docs/apache-airflow/concepts/pools.rst | 42 +-
docs/apache-airflow/concepts/smart-sensors.rst | 26 +-
docs/apache-airflow/concepts/tasks.rst | 4 +-
docs/apache-airflow/concepts/xcoms.rst | 40 +-
docs/apache-airflow/dag-run.rst | 33 +-
docs/apache-airflow/executor/kubernetes.rst | 11 +-
docs/apache-airflow/faq.rst | 34 +-
.../howto/create-custom-decorator.rst | 2 +-
docs/apache-airflow/howto/email-config.rst | 7 +
docs/apache-airflow/howto/operator/python.rst | 10 +
docs/apache-airflow/howto/set-up-database.rst | 4 +-
docs/apache-airflow/howto/timetable.rst | 8 +-
docs/apache-airflow/howto/variable.rst | 3 +-
docs/apache-airflow/installation/index.rst | 4 +-
.../installation/installing-from-pypi.rst | 9 +-
.../installation/installing-from-sources.rst | 2 +-
.../installation/supported-versions.rst | 28 +-
docs/apache-airflow/installation/upgrading.rst | 15 +
docs/apache-airflow/lineage.rst | 16 +-
.../logging-monitoring/callbacks.rst | 8 +-
docs/apache-airflow/logging-monitoring/errors.rst | 15 +-
.../logging-monitoring/logging-tasks.rst | 38 +-
docs/apache-airflow/logging-monitoring/metrics.rst | 10 +-
docs/apache-airflow/migrations-ref.rst | 6 +-
docs/apache-airflow/modules_management.rst | 10 +-
docs/apache-airflow/pipeline_example.csv | 190 ++--
docs/apache-airflow/python-api-ref.rst | 6 +
docs/apache-airflow/security/api.rst | 3 +-
docs/apache-airflow/start/docker.rst | 2 +
docs/apache-airflow/start/local.rst | 3 +
docs/apache-airflow/templates-ref.rst | 4 +-
docs/apache-airflow/timezone.rst | 29 +-
docs/apache-airflow/tutorial.rst | 163 +--
docs/apache-airflow/tutorial_taskflow_api.rst | 44 +
docs/apache-airflow/upgrading-from-1-10/index.rst | 15 +
docs/conf.py | 23 +-
docs/docker-stack/README.md | 75 ++
docs/docker-stack/build-arg-ref.rst | 14 +-
docs/docker-stack/build.rst | 59 +-
.../customizing/add-build-essential-custom.sh | 7 +-
.../docker-examples/customizing/custom-sources.sh | 7 +-
.../customizing/github-different-repository.sh | 1 +
.../docker-examples/customizing/github-main.sh | 1 +
.../{github-v2-1-test.sh => github-v2-2-test.sh} | 9 +-
.../customizing/pypi-dev-runtime-deps.sh | 7 +-
.../customizing/pypi-extras-and-deps.sh | 5 +-
.../customizing/pypi-selected-version.sh | 5 +-
.../extending/add-apt-packages/Dockerfile | 2 +-
.../add-build-essential-extend/Dockerfile | 2 +-
.../extending/add-providers/Dockerfile | 2 +-
.../extending/add-pypi-packages/Dockerfile | 2 +-
.../extending/embedding-dags/Dockerfile | 2 +-
.../extending/embedding-dags/test_dag.py | 18 +-
.../extending/writable-directory/Dockerfile | 2 +-
.../restricted/restricted_environments.sh | 13 +-
.../docker-images-recipes/gcloud.Dockerfile | 1 +
docs/docker-stack/entrypoint.rst | 24 +-
docs/docker-stack/index.rst | 9 +-
docs/docker-stack/recipes.rst | 2 +
docs/exts/docs_build/docs_builder.py | 5 +-
docs/exts/docs_build/run_patched_sphinx.py | 105 --
docs/exts/exampleinclude.py | 10 +-
.../installing-helm-chart-from-sources.rst | 2 +-
docs/helm-chart/manage-dags-files.rst | 4 +-
docs/helm-chart/quick-start.rst | 6 +-
docs/installing-providers-from-sources.rst | 2 +-
docs/publish_docs.py | 2 +-
docs/spelling_wordlist.txt | 29 +-
licenses/LICENSE-connexion.txt | 9 -
scripts/ci/constraints/ci_branch_constraints.sh | 7 +-
scripts/ci/constraints/ci_commit_constraints.sh | 3 +-
scripts/ci/docker-compose/_docker.env | 4 +-
scripts/ci/docker-compose/_docker_compose.env | 49 -
scripts/ci/docker-compose/backend-mssql.yml | 8 +-
scripts/ci/docker-compose/base.yml | 56 +-
scripts/ci/docker-compose/integration-pinot.yml | 2 +-
scripts/ci/docker-compose/integration-statsd.yml | 2 +-
scripts/ci/docker-compose/local.yml | 1 +
scripts/ci/images/ci_prepare_ci_image_on_ci.sh | 5 -
scripts/ci/images/ci_prepare_prod_image_on_ci.sh | 4 -
scripts/ci/images/ci_push_ci_images.sh | 10 +-
scripts/ci/images/ci_push_production_images.sh | 11 +-
...h => ci_run_docker_compose_quick_start_test.sh} | 11 +-
scripts/ci/images/ci_run_docker_tests.py | 96 ++
scripts/ci/images/ci_run_prod_image_test.sh | 2 +-
.../ci_test_examples_of_prod_image_building.sh | 70 +-
.../images/ci_wait_for_and_verify_all_ci_images.sh | 2 +
.../ci_wait_for_and_verify_all_prod_images.sh | 2 +
.../ci/images/ci_wait_for_and_verify_ci_image.sh | 2 +
scripts/ci/installed_providers.txt | 22 +
scripts/ci/kubernetes/ci_run_helm_upgrade.sh | 6 +-
scripts/ci/kubernetes/ci_run_kubernetes_tests.sh | 11 +-
scripts/ci/libraries/_all_libs.sh | 2 -
scripts/ci/libraries/_build_images.sh | 454 +++------
scripts/ci/libraries/_docker_engine_resources.sh | 2 +-
scripts/ci/libraries/_initialization.sh | 135 ++-
scripts/ci/libraries/_kind.sh | 3 +
scripts/ci/libraries/_local_mounts.sh | 1 +
scripts/ci/libraries/_md5sum.sh | 19 -
scripts/ci/libraries/_push_pull_remove_images.sh | 214 +---
scripts/ci/libraries/_runs.sh | 10 +-
scripts/ci/libraries/_spinner.sh | 55 -
scripts/ci/libraries/_start_end.sh | 22 -
scripts/ci/libraries/_testing.sh | 16 +-
scripts/ci/libraries/_verbosity.sh | 2 +-
scripts/ci/libraries/_verify_image.sh | 366 +------
.../pre_commit_checkout_no_credentials.py | 87 ++
scripts/ci/pre_commit/pre_commit_ci_build.sh | 30 +-
scripts/ci/pre_commit/pre_commit_flake8.sh | 2 +-
scripts/ci/pre_commit/pre_commit_mypy.sh | 5 +-
.../ci/pre_commit/pre_commit_update_versions.py | 32 +-
scripts/ci/pre_commit/supported_versions.py | 63 ++
.../ci_install_and_test_provider_packages.sh | 2 +-
.../ci/static_checks/in_container_bats_tests.sh | 4 +-
scripts/ci/static_checks/mypy.sh | 2 +-
scripts/ci/static_checks/ui_lint.sh | 2 +-
scripts/ci/static_checks/www_lint.sh | 2 +-
scripts/ci/testing/ci_run_airflow_testing.sh | 73 +-
.../ci_run_single_airflow_test_in_docker.sh | 27 +-
scripts/ci/tools/build_dockerhub.sh | 1 -
scripts/ci/tools/fix_ownership.sh | 6 +-
scripts/ci/tools/verify_docker_image.sh | 57 --
scripts/docker/common.sh | 34 +-
scripts/docker/compile_www_assets.sh | 46 +-
scripts/docker/install_additional_dependencies.sh | 30 +-
scripts/docker/install_airflow.sh | 32 +-
...install_airflow_dependencies_from_branch_tip.sh | 16 +-
.../docker/install_from_docker_context_files.sh | 26 +-
scripts/docker/install_mssql.sh | 15 +-
scripts/docker/install_mysql.sh | 16 +-
scripts/docker/install_pip_version.sh | 20 +-
...mpile_www_assets.sh => prepare_node_modules.sh} | 35 +-
scripts/in_container/_in_container_utils.sh | 18 +-
scripts/in_container/bin/run_tmux | 18 +-
scripts/in_container/check_environment.sh | 58 +-
scripts/in_container/check_junitxml_result.py | 56 +
scripts/in_container/entrypoint_ci.sh | 19 +-
scripts/in_container/prod/entrypoint_prod.sh | 2 +-
scripts/in_container/run_generate_constraints.sh | 2 +-
.../run_install_and_test_provider_packages.sh | 22 +
.../in_container/run_prepare_airflow_packages.sh | 2 +-
scripts/in_container/run_resource_check.sh | 4 +-
scripts/in_container/run_tmux_welcome.sh | 4 +-
setup.cfg | 53 +-
setup.py | 69 +-
tests/always/test_project_structure.py | 4 +
tests/api/client/test_local_client.py | 31 +-
.../common/{experimental => }/test_delete_dag.py | 16 +-
.../common/{experimental => }/test_trigger_dag.py | 8 +-
tests/api_connexion/conftest.py | 7 +-
tests/api_connexion/test_security.py | 4 +
tests/cli/commands/test_dag_command.py | 4 +-
tests/cli/commands/test_task_command.py | 3 +-
tests/conftest.py | 12 +-
tests/core/test_core.py | 21 +-
tests/core/test_stats.py | 5 +
tests/dag_processing/test_manager.py | 3 +
tests/decorators/test_python.py | 23 +-
tests/jobs/test_scheduler_job.py | 170 ++--
tests/models/test_pool.py | 71 ++
tests/models/test_taskinstance.py | 31 +
tests/operators/test_email.py | 2 +-
tests/operators/test_python.py | 9 +-
tests/operators/test_trigger_dagrun.py | 62 +-
.../amazon/aws/hooks/test_cloud_formation.py | 19 +-
tests/providers/amazon/aws/hooks/test_logs.py | 4 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 34 +-
tests/providers/amazon/aws/utils/test_emailer.py | 42 +-
.../docker/operators/test_docker_swarm.py | 48 -
.../providers/google/cloud/hooks/test_dataproc.py | 120 ++-
.../google/cloud/hooks/test_dataproc_metastore.py | 489 +++++++++
.../google/cloud/operators/test_dataproc.py | 126 +++
.../cloud/operators/test_dataproc_metastore.py | 396 ++++++++
...system.py => test_dataproc_metastore_system.py} | 31 +-
.../google/cloud/operators/test_dataproc_system.py | 4 +
.../google/cloud/sensors/test_dataproc.py | 2 +-
tests/providers/http/sensors/test_http.py | 4 +-
.../yandex/operators/test_yandexcloud_dataproc.py | 11 +
tests/sensors/test_external_task_sensor.py | 15 +-
tests/task/__init__.py | 2 -
.../task/task_runner/test_standard_task_runner.py | 2 +
tests/test_utils/asserts.py | 12 +-
tests/test_utils/decorators.py | 2 +-
tests/timetables/test_interval_timetable.py | 21 +
tests/utils/test_db.py | 3 +
tests/utils/test_email.py | 14 +
tests/utils/test_log_handlers.py | 6 +-
tests/www/views/conftest.py | 1 +
tests/www/views/test_session.py | 65 ++
tests/www/views/test_views.py | 35 +-
tests/www/views/test_views_base.py | 1 +
tests/www/views/test_views_dagrun.py | 23 +-
tests/www/views/test_views_tasks.py | 4 +-
tests/www/views/test_views_trigger_dag.py | 11 +-
428 files changed, 10841 insertions(+), 10553 deletions(-)
delete mode 100755 airflow/_vendor/connexion/__init__.py
delete mode 100644 airflow/_vendor/connexion/__main__.py
delete mode 100644 airflow/_vendor/connexion/apis/__init__.py
delete mode 100644 airflow/_vendor/connexion/apis/abstract.py
delete mode 100644 airflow/_vendor/connexion/apis/aiohttp_api.py
delete mode 100644 airflow/_vendor/connexion/apis/flask_api.py
delete mode 100644 airflow/_vendor/connexion/apis/flask_utils.py
delete mode 100644 airflow/_vendor/connexion/apps/__init__.py
delete mode 100644 airflow/_vendor/connexion/apps/abstract.py
delete mode 100644 airflow/_vendor/connexion/apps/aiohttp_app.py
delete mode 100644 airflow/_vendor/connexion/apps/flask_app.py
delete mode 100644 airflow/_vendor/connexion/cli.py
delete mode 100644 airflow/_vendor/connexion/decorators/__init__.py
delete mode 100644 airflow/_vendor/connexion/decorators/coroutine_wrappers.py
delete mode 100644 airflow/_vendor/connexion/decorators/decorator.py
delete mode 100644 airflow/_vendor/connexion/decorators/metrics.py
delete mode 100644 airflow/_vendor/connexion/decorators/parameter.py
delete mode 100644 airflow/_vendor/connexion/decorators/produces.py
delete mode 100644 airflow/_vendor/connexion/decorators/response.py
delete mode 100644 airflow/_vendor/connexion/decorators/security.py
delete mode 100644 airflow/_vendor/connexion/decorators/uri_parsing.py
delete mode 100644 airflow/_vendor/connexion/decorators/validation.py
delete mode 100644 airflow/_vendor/connexion/exceptions.py
delete mode 100644 airflow/_vendor/connexion/handlers.py
delete mode 100644 airflow/_vendor/connexion/http_facts.py
delete mode 100644 airflow/_vendor/connexion/json_schema.py
delete mode 100644 airflow/_vendor/connexion/jsonifier.py
delete mode 100644 airflow/_vendor/connexion/lifecycle.py
delete mode 100644 airflow/_vendor/connexion/mock.py
delete mode 100644 airflow/_vendor/connexion/operations/__init__.py
delete mode 100644 airflow/_vendor/connexion/operations/abstract.py
delete mode 100644 airflow/_vendor/connexion/operations/compat.py
delete mode 100644 airflow/_vendor/connexion/operations/openapi.py
delete mode 100644 airflow/_vendor/connexion/operations/secure.py
delete mode 100644 airflow/_vendor/connexion/operations/swagger2.py
delete mode 100644 airflow/_vendor/connexion/options.py
delete mode 100644 airflow/_vendor/connexion/problem.py
delete mode 100644 airflow/_vendor/connexion/resolver.py
delete mode 100644 airflow/_vendor/connexion/setup.cfg
delete mode 100755 airflow/_vendor/connexion/setup.py
delete mode 100644 airflow/_vendor/connexion/spec.py
delete mode 100644 airflow/_vendor/connexion/utils.py
copy airflow/api/common/{experimental => }/delete_dag.py (82%)
copy airflow/api/common/{experimental => }/trigger_dag.py (95%)
copy airflow/{kubernetes/pod.py => migrations/versions/587bdf053233_adding_index_for_dag_id_in_job.py} (59%)
copy tests/providers/amazon/aws/utils/test_emailer.py => airflow/migrations/versions/c381b21cb7e4_add_session_table_to_db.py (50%)
create mode 100644 airflow/providers/google/cloud/example_dags/example_dataproc_metastore.py
create mode 100644 airflow/providers/google/cloud/hooks/dataproc_metastore.py
create mode 100644 airflow/providers/google/cloud/operators/dataproc_metastore.py
copy airflow/www/{extensions/init_session.py => session.py} (59%)
create mode 100644 dev/ISSUE_TEMPLATE.md.jinja2
create mode 100755 dev/chart/build_changelog_annotations.py
rename {scripts/ci/tools => dev}/prepare_prod_docker_images.sh (57%)
create mode 100755 dev/prepare_release_issue.py
copy {tests/timetables => docker_tests}/__init__.py (100%)
copy airflow/api/common/experimental/get_code.py => docker_tests/command_utils.py (52%)
copy tests/task/__init__.py => docker_tests/constants.py (91%)
create mode 100644 docker_tests/docker_tests_utils.py
copy airflow/kubernetes/volume.py => docker_tests/test_ci_image.py (52%)
create mode 100644 docker_tests/test_docker_compose_quick_start.py
create mode 100644 docker_tests/test_examples_of_prod_image_building.py
create mode 100644 docker_tests/test_prod_image.py
create mode 100644 docs/apache-airflow-providers-google/operators/cloud/dataproc_metastore.rst
create mode 100644 docs/docker-stack/README.md
rename docs/docker-stack/docker-examples/customizing/{github-v2-1-test.sh => github-v2-2-test.sh} (84%)
delete mode 100755 docs/exts/docs_build/run_patched_sphinx.py
delete mode 100644 licenses/LICENSE-connexion.txt
delete mode 100644 scripts/ci/docker-compose/_docker_compose.env
copy scripts/ci/images/{ci_push_production_images.sh => ci_run_docker_compose_quick_start_test.sh} (72%)
create mode 100755 scripts/ci/images/ci_run_docker_tests.py
create mode 100644 scripts/ci/installed_providers.txt
delete mode 100644 scripts/ci/libraries/_spinner.sh
create mode 100755 scripts/ci/pre_commit/pre_commit_checkout_no_credentials.py
create mode 100755 scripts/ci/pre_commit/supported_versions.py
delete mode 100755 scripts/ci/tools/verify_docker_image.sh
copy scripts/docker/{compile_www_assets.sh => prepare_node_modules.sh} (63%)
create mode 100755 scripts/in_container/check_junitxml_result.py
rename tests/api/common/{experimental => }/test_delete_dag.py (91%)
rename tests/api/common/{experimental => }/test_trigger_dag.py (93%)
create mode 100644 tests/providers/google/cloud/hooks/test_dataproc_metastore.py
create mode 100644 tests/providers/google/cloud/operators/test_dataproc_metastore.py
copy tests/providers/google/cloud/operators/{test_dataproc_system.py => test_dataproc_metastore_system.py} (62%)
create mode 100644 tests/www/views/test_session.py