This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 6cd19b0b4e Quieter output during asset compilation (#30565)
add a1b99fe536 Rename JobRunner modules to *_job_runner and base_job* to
job (#30302)
No new revisions were added by this update.
Summary of changes:
airflow/api_connexion/endpoints/health_endpoint.py | 4 +-
airflow/api_connexion/schemas/job_schema.py | 4 +-
airflow/cli/commands/dag_command.py | 10 +-
airflow/cli/commands/dag_processor_command.py | 6 +-
airflow/cli/commands/jobs_command.py | 17 +-
airflow/cli/commands/scheduler_command.py | 8 +-
airflow/cli/commands/standalone_command.py | 8 +-
airflow/cli/commands/task_command.py | 6 +-
airflow/cli/commands/triggerer_command.py | 6 +-
airflow/dag_processing/manager.py | 6 +-
airflow/executors/celery_executor.py | 2 +-
.../{backfill_job.py => backfill_job_runner.py} | 6 +-
airflow/jobs/{job_runner.py => base_job_runner.py} | 10 +-
...rocessor_job.py => dag_processor_job_runner.py} | 2 +-
airflow/jobs/{base_job.py => job.py} | 34 ++-
...{local_task_job.py => local_task_job_runner.py} | 4 +-
.../{scheduler_job.py => scheduler_job_runner.py} | 26 +-
.../{triggerer_job.py => triggerer_job_runner.py} | 4 +-
airflow/models/__init__.py | 2 +-
airflow/models/dag.py | 6 +-
airflow/models/taskinstance.py | 8 +-
airflow/models/trigger.py | 14 +-
.../serialization/pydantic/{base_job.py => job.py} | 6 +-
airflow/serialization/serialized_objects.py | 10 +-
airflow/task/task_runner/__init__.py | 2 +-
airflow/task/task_runner/base_task_runner.py | 6 +-
airflow/task/task_runner/cgroup_task_runner.py | 4 +-
airflow/task/task_runner/standard_task_runner.py | 4 +-
airflow/utils/scheduler_health.py | 8 +-
airflow/www/views.py | 8 +-
dev/perf/scheduler_dag_execution_timing.py | 10 +-
dev/perf/sql_queries.py | 6 +-
.../logging-monitoring/check-health.rst | 2 +-
.../endpoints/test_health_endpoint.py | 12 +-
.../endpoints/test_task_instance_endpoint.py | 6 +-
tests/cli/commands/test_dag_processor_command.py | 2 +-
tests/cli/commands/test_jobs_command.py | 14 +-
tests/core/test_impersonation_tests.py | 6 +-
tests/executors/test_dask_executor.py | 6 +-
tests/jobs/test_backfill_job.py | 114 ++++----
tests/jobs/test_base_job.py | 44 ++-
tests/jobs/test_local_task_job.py | 58 ++--
tests/jobs/test_scheduler_job.py | 312 ++++++++++-----------
tests/jobs/test_triggerer_job.py | 36 +--
tests/jobs/test_triggerer_job_logging.py | 46 +--
tests/listeners/test_listeners.py | 4 +-
tests/models/test_trigger.py | 14 +-
tests/serialization/test_pydantic_models.py | 12 +-
tests/task/task_runner/test_base_task_runner.py | 6 +-
tests/task/task_runner/test_cgroup_task_runner.py | 10 +-
.../task/task_runner/test_standard_task_runner.py | 64 ++---
tests/task/task_runner/test_task_runner.py | 16 +-
tests/test_utils/db.py | 6 +-
tests/utils/test_helpers.py | 2 +-
tests/utils/test_log_handlers.py | 8 +-
tests/www/views/test_views_base.py | 34 +--
56 files changed, 531 insertions(+), 560 deletions(-)
rename airflow/jobs/{backfill_job.py => backfill_job_runner.py} (99%)
rename airflow/jobs/{job_runner.py => base_job_runner.py} (89%)
rename airflow/jobs/{dag_processor_job.py => dag_processor_job_runner.py} (96%)
rename airflow/jobs/{base_job.py => job.py} (91%)
rename airflow/jobs/{local_task_job.py => local_task_job_runner.py} (99%)
rename airflow/jobs/{scheduler_job.py => scheduler_job_runner.py} (98%)
rename airflow/jobs/{triggerer_job.py => triggerer_job_runner.py} (99%)
rename airflow/serialization/pydantic/{base_job.py => job.py} (89%)
