You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2020/10/09 22:19:28 UTC
[airflow] branch master updated (e198077 -> 73b9163)
This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from e198077 Add pypirc initialization (#11386)
add 73b9163 Fully support running more than one scheduler concurrently (#10956)
No new revisions were added by this update.
Summary of changes:
airflow/api/common/experimental/trigger_dag.py | 1 +
airflow/cli/cli_parser.py | 2 +-
airflow/cli/commands/scheduler_command.py | 1 -
airflow/config_templates/config.yml | 44 +
airflow/config_templates/default_airflow.cfg | 28 +
airflow/executors/base_executor.py | 33 +-
airflow/executors/celery_kubernetes_executor.py | 22 +-
airflow/jobs/scheduler_job.py | 1210 +++++-----
...606e2_add_scheduling_decision_to_dagrun_and_.py | 88 +
airflow/models/dag.py | 301 ++-
airflow/models/dagbag.py | 36 +-
airflow/models/dagrun.py | 124 +-
airflow/models/pool.py | 19 +-
airflow/models/serialized_dag.py | 34 +-
airflow/models/taskinstance.py | 28 +-
airflow/settings.py | 14 +
airflow/stats.py | 58 +
airflow/ti_deps/deps/not_previously_skipped_dep.py | 2 +-
airflow/utils/callback_requests.py | 101 +
airflow/utils/dag_processing.py | 164 +-
airflow/utils/sqlalchemy.py | 124 ++
airflow/www/views.py | 1 +
docs/logging-monitoring/metrics.rst | 15 +-
docs/spelling_wordlist.txt | 1 +
tests/api/client/test_local_client.py | 14 +-
tests/api/common/experimental/test_trigger_dag.py | 4 +
tests/dags/test_zip.zip | Bin 2204 -> 2977 bytes
tests/jobs/test_backfill_job.py | 23 +-
tests/jobs/test_scheduler_job.py | 2356 ++++++++++----------
tests/models/test_dag.py | 566 +++--
tests/models/test_dagrun.py | 131 +-
.../task/task_runner/test_standard_task_runner.py | 1 +
tests/test_utils/mock_executor.py | 3 +-
tests/test_utils/perf/perf_kit/__init__.py | 10 +-
tests/test_utils/perf/perf_kit/python.py | 2 +-
tests/test_utils/perf/perf_kit/sqlalchemy.py | 2 +-
tests/ti_deps/deps/test_runnable_exec_date_dep.py | 19 +-
tests/utils/test_dag_processing.py | 115 +-
tests/utils/test_sqlalchemy.py | 14 +-
tests/www/test_views.py | 18 +-
40 files changed, 3423 insertions(+), 2306 deletions(-)
create mode 100644 airflow/migrations/versions/98271e7606e2_add_scheduling_decision_to_dagrun_and_.py
create mode 100644 airflow/utils/callback_requests.py