This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 14919fae914 Convert the LocalExecutor to run tasks using new Task SDK
supervisor code (#44427)
add 3862e172489 Get rid of database isolation option (#44441)
No new revisions were added by this update.
Summary of changes:
Dockerfile.ci | 40 ---
airflow/utils/session.py | 18 --
contributing-docs/testing/unit_tests.rst | 34 ---
dev/breeze/doc/images/output-commands.svg | 148 +++++------
dev/breeze/doc/images/output_shell.svg | 292 ++++++++++-----------
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 206 +++++++--------
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
.../doc/images/output_testing_providers-tests.svg | 118 ++++-----
.../doc/images/output_testing_providers-tests.txt | 2 +-
.../src/airflow_breeze/commands/common_options.py | 6 -
.../airflow_breeze/commands/developer_commands.py | 7 -
.../commands/developer_commands_config.py | 3 -
.../src/airflow_breeze/commands/main_command.py | 2 -
.../airflow_breeze/commands/testing_commands.py | 6 -
.../commands/testing_commands_config.py | 8 -
.../src/airflow_breeze/params/shell_params.py | 2 -
providers/tests/airbyte/hooks/test_airbyte.py | 2 +-
.../aws/auth_manager/cli/test_avp_commands.py | 2 -
.../test_aws_security_manager_override.py | 2 -
.../aws/auth_manager/test_aws_auth_manager.py | 5 +-
.../amazon/aws/auth_manager/views/test_auth.py | 5 +-
.../amazon/aws/transfers/test_google_api_to_s3.py | 2 +-
providers/tests/apache/druid/hooks/test_druid.py | 3 -
providers/tests/apache/livy/hooks/test_livy.py | 2 -
providers/tests/arangodb/sensors/test_arangodb.py | 2 +-
.../tests/asana/operators/test_asana_tasks.py | 2 +-
.../tests/celery/log_handlers/test_log_handlers.py | 2 +-
.../executors/test_kubernetes_executor.py | 2 -
.../kubernetes/log_handlers/test_log_handlers.py | 2 +-
.../tests/cncf/kubernetes/operators/test_pod.py | 2 +-
.../cncf/kubernetes/test_template_rendering.py | 2 +-
providers/tests/common/io/xcom/test_backend.py | 121 ++++-----
providers/tests/common/sql/operators/test_sql.py | 5 +-
providers/tests/common/sql/sensors/test_sql.py | 5 +-
.../tests/edge/worker_api/routes/test_rpc_api.py | 2 +-
.../api_endpoints/test_asset_endpoint.py | 1 -
.../fab/auth_manager/api_endpoints/test_auth.py | 1 -
.../fab/auth_manager/api_endpoints/test_cors.py | 1 -
.../api_endpoints/test_dag_endpoint.py | 1 -
.../api_endpoints/test_dag_run_endpoint.py | 1 -
.../api_endpoints/test_dag_source_endpoint.py | 1 -
.../api_endpoints/test_dag_warning_endpoint.py | 1 -
.../api_endpoints/test_event_log_endpoint.py | 1 -
.../api_endpoints/test_import_error_endpoint.py | 1 -
.../api_endpoints/test_task_instance_endpoint.py | 1 -
.../api_endpoints/test_variable_endpoint.py | 1 -
.../api_endpoints/test_xcom_endpoint.py | 1 -
.../schemas/test_role_and_permission_schema.py | 2 +-
.../common/auth_backend/test_google_openid.py | 1 -
.../operators/test_campaign_manager.py | 1 -
.../operators/test_display_video.py | 1 -
.../tests/openlineage/plugins/test_execution.py | 1 -
providers/tests/standard/operators/test_python.py | 12 -
.../tests/standard/sensors/test_time_delta.py | 1 -
providers/tests/standard/sensors/test_weekday.py | 3 -
.../tests/standard/triggers/test_external_task.py | 1 -
scripts/docker/entrypoint_ci.sh | 40 ---
scripts/in_container/bin/run_tmux | 6 -
task_sdk/tests/defintions/test_asset.py | 1 -
tests/always/test_example_dags.py | 1 -
.../api_connexion/endpoints/test_asset_endpoint.py | 2 +-
.../endpoints/test_config_endpoint.py | 2 +-
.../endpoints/test_connection_endpoint.py | 2 +-
tests/api_connexion/endpoints/test_dag_endpoint.py | 2 +-
tests/api_connexion/endpoints/test_dag_parsing.py | 2 +-
.../endpoints/test_dag_run_endpoint.py | 2 +-
.../endpoints/test_dag_source_endpoint.py | 2 +-
.../endpoints/test_dag_stats_endpoint.py | 2 +-
.../endpoints/test_dag_warning_endpoint.py | 2 +-
.../endpoints/test_event_log_endpoint.py | 2 +-
.../endpoints/test_extra_link_endpoint.py | 2 +-
.../endpoints/test_health_endpoint.py | 2 +-
.../endpoints/test_import_error_endpoint.py | 2 +-
tests/api_connexion/endpoints/test_log_endpoint.py | 2 +-
.../test_mapped_task_instance_endpoint.py | 2 +-
.../endpoints/test_plugin_endpoint.py | 2 +-
.../api_connexion/endpoints/test_pool_endpoint.py | 2 +-
.../endpoints/test_provider_endpoint.py | 2 +-
.../api_connexion/endpoints/test_task_endpoint.py | 2 +-
.../endpoints/test_task_instance_endpoint.py | 2 +-
.../endpoints/test_variable_endpoint.py | 2 +-
.../endpoints/test_version_endpoint.py | 2 +-
.../api_connexion/endpoints/test_xcom_endpoint.py | 2 +-
tests/api_connexion/schemas/test_asset_schema.py | 2 +-
.../schemas/test_connection_schema.py | 2 +-
tests/api_connexion/schemas/test_dag_run_schema.py | 2 +-
tests/api_connexion/schemas/test_dag_schema.py | 2 -
tests/api_connexion/schemas/test_error_schema.py | 2 +-
.../api_connexion/schemas/test_event_log_schema.py | 2 +-
tests/api_connexion/schemas/test_pool_schemas.py | 2 +-
.../schemas/test_task_instance_schema.py | 1 -
tests/api_connexion/schemas/test_xcom_schema.py | 2 +-
tests/api_connexion/test_auth.py | 2 +-
tests/api_connexion/test_error_handling.py | 2 +-
tests/api_connexion/test_security.py | 2 +-
.../core_api/routes/public/test_assets.py | 2 +-
.../core_api/routes/public/test_extra_links.py | 2 +-
.../core_api/routes/public/test_monitor.py | 2 +-
.../core_api/routes/public/test_pools.py | 2 +-
.../core_api/routes/public/test_providers.py | 2 +-
.../core_api/routes/public/test_version.py | 2 +-
.../endpoints/test_rpc_api_endpoint.py | 2 +-
tests/assets/test_manager.py | 2 -
tests/cli/commands/test_backfill_command.py | 2 +-
tests/cli/commands/test_celery_command.py | 2 +-
tests/cli/commands/test_connection_command.py | 2 +-
tests/cli/commands/test_dag_command.py | 2 +-
tests/cli/commands/test_dag_processor_command.py | 2 +-
tests/cli/commands/test_db_command.py | 2 +-
tests/cli/commands/test_jobs_command.py | 1 -
tests/cli/commands/test_kerberos_command.py | 2 +-
tests/cli/commands/test_kubernetes_command.py | 2 +-
tests/cli/commands/test_plugins_command.py | 2 +-
tests/cli/commands/test_pool_command.py | 2 +-
.../cli/commands/test_rotate_fernet_key_command.py | 2 +-
tests/cli/commands/test_scheduler_command.py | 2 +-
tests/cli/commands/test_task_command.py | 2 +-
tests/cli/commands/test_triggerer_command.py | 2 +-
tests/cli/commands/test_variable_command.py | 2 +-
tests/core/test_core.py | 2 +-
tests/core/test_sentry.py | 2 -
tests/core/test_settings.py | 54 +---
tests/core/test_sqlalchemy_config.py | 2 +-
tests/dag_processing/test_job_runner.py | 9 -
tests/dag_processing/test_processor.py | 20 --
tests/decorators/test_bash.py | 15 --
tests/decorators/test_branch_external_python.py | 1 -
tests/decorators/test_branch_python.py | 1 -
tests/decorators/test_branch_virtualenv.py | 1 -
tests/decorators/test_condition.py | 4 -
tests/decorators/test_python.py | 15 --
tests/decorators/test_sensor.py | 6 -
tests/decorators/test_short_circuit.py | 1 -
tests/executors/test_base_executor.py | 2 -
tests/executors/test_executor_loader.py | 2 -
tests/executors/test_local_executor.py | 2 +-
tests/jobs/test_base_job.py | 2 -
tests/jobs/test_local_task_job.py | 17 --
tests/jobs/test_scheduler_job.py | 2 +-
tests/jobs/test_triggerer_job.py | 12 -
tests/lineage/test_lineage.py | 2 -
tests/listeners/test_asset_listener.py | 1 -
tests/listeners/test_dag_import_error_listener.py | 2 -
tests/listeners/test_listeners.py | 5 -
tests/models/test_base.py | 2 +-
tests/models/test_baseoperator.py | 2 -
tests/models/test_baseoperatormeta.py | 7 -
tests/models/test_cleartasks.py | 2 +-
tests/models/test_dag.py | 2 +-
tests/models/test_dag_version.py | 2 +-
tests/models/test_dagbag.py | 11 -
tests/models/test_dagcode.py | 2 +-
tests/models/test_dagrun.py | 2 +-
tests/models/test_dagwarning.py | 2 +-
tests/models/test_mappedoperator.py | 26 --
tests/models/test_param.py | 3 -
tests/models/test_pool.py | 2 +-
tests/models/test_renderedtifields.py | 7 -
tests/models/test_serialized_dag.py | 7 -
tests/models/test_skipmixin.py | 2 -
tests/models/test_taskinstance.py | 91 -------
tests/models/test_trigger.py | 5 -
tests/models/test_variable.py | 10 -
tests/models/test_xcom.py | 9 +-
tests/models/test_xcom_arg.py | 1 -
tests/models/test_xcom_arg_map.py | 8 -
tests/operators/test_trigger_dagrun.py | 11 -
tests/plugins/test_plugins_manager.py | 2 -
tests/sensors/test_base.py | 1 -
tests/sensors/test_external_task_sensor.py | 43 ---
tests/sensors/test_filesystem.py | 1 -
tests/serialization/test_pydantic_models.py | 2 -
tests/task/test_standard_task_runner.py | 5 -
.../deps/test_dag_ti_slots_available_dep.py | 2 +-
tests/ti_deps/deps/test_dag_unpaused_dep.py | 2 +-
tests/ti_deps/deps/test_dagrun_exists_dep.py | 2 +-
.../ti_deps/deps/test_mapped_task_upstream_dep.py | 2 +-
tests/ti_deps/deps/test_not_in_retry_period_dep.py | 2 +-
.../deps/test_not_previously_skipped_dep.py | 2 +-
.../ti_deps/deps/test_pool_slots_available_dep.py | 2 +-
tests/ti_deps/deps/test_prev_dagrun_dep.py | 2 +-
tests/ti_deps/deps/test_ready_to_reschedule_dep.py | 2 +-
tests/ti_deps/deps/test_runnable_exec_date_dep.py | 2 +-
tests/ti_deps/deps/test_task_concurrency.py | 2 +-
tests/ti_deps/deps/test_task_not_running_dep.py | 2 +-
tests/ti_deps/deps/test_trigger_rule_dep.py | 2 +-
tests/ti_deps/deps/test_valid_state_dep.py | 2 +-
tests/utils/log/test_colored_log.py | 2 +-
tests/utils/log/test_log_reader.py | 2 +-
tests/utils/test_cli_util.py | 2 +-
tests/utils/test_db.py | 2 +-
tests/utils/test_db_cleanup.py | 2 +-
tests/utils/test_dot_renderer.py | 2 +-
tests/utils/test_email.py | 2 -
tests/utils/test_helpers.py | 2 -
tests/utils/test_log_handlers.py | 2 +-
tests/utils/test_process_utils.py | 4 -
tests/utils/test_retries.py | 2 -
tests/utils/test_session.py | 2 +-
tests/utils/test_sqlalchemy.py | 2 +-
tests/utils/test_state.py | 2 +-
.../test_task_handler_with_custom_formatter.py | 1 -
tests/utils/test_types.py | 2 +-
tests/utils/test_usage_data_collection.py | 1 -
tests/www/test_app.py | 2 +-
tests/www/test_auth.py | 2 -
tests/www/test_security_manager.py | 2 -
tests/www/test_utils.py | 6 -
tests_common/pytest_plugin.py | 28 --
tests_common/test_utils/db.py | 6 -
211 files changed, 539 insertions(+), 1286 deletions(-)
