This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch v2-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git.
discard abc86c4 Don't fail to log if we can't redact something (#16118)
discard fb714d6 set max tree width to 1200px (#16067)
discard 789aace Ensure that we don't try to mask empty string in logs (#16057)
omit 779811e Fill the "job_id" field for `airflow task run` without
`--local`/`--raw` for KubeExecutor (#16108)
omit 194762f Fixes problem where conf variable was used before
initialization (#16088)
omit 3c169fb Fix apply defaults for task decorator (#16085)
omit fcf95fe Parse recently modified files even if just parsed (#16075)
omit 47ca826 Ensure that we don't try to mask empty string in logs (#16057)
omit 554a13d Don't die when masking `log.exception` when there is no
exception (#16047)
omit ec03f81 Restores apply_defaults import in base_sensor_operator
(#16040)
omit 79c99e9 Fix auto-refresh in tree view When webserver ui is not in
``/`` (#16018)
omit 8dcbdcd Fix Celery executor getting stuck randomly because of
reset_signals in multiprocessing (#15989)
omit 589be33 Fix dag.clear() to set multiple dags to running when
necessary (#15382)
omit bdf9bc2 Fix dag.clear() to set multiple dags to running when
necessary (#15382)
new 955de9b Fix dag.clear() to set multiple dags to running when
necessary (#15382)
new dc26721 Fix auto-refresh in tree view When webserver ui is not in
``/`` (#16018)
new 2cd66a8 Restores apply_defaults import in base_sensor_operator
(#16040)
new 19332cf Don't die when masking `log.exception` when there is no
exception (#16047)
new c47171b Ensure that we don't try to mask empty string in logs (#16057)
new 734f1dc Parse recently modified files even if just parsed (#16075)
new 4e431ec Fix apply defaults for task decorator (#16085)
new 9a3fb62 Fixes problem where conf variable was used before
initialization (#16088)
new b9e5a2d Fill the "job_id" field for `airflow task run` without
`--local`/`--raw` for KubeExecutor (#16108)
new bff528b Ensure that we don't try to mask empty string in logs (#16057)
new eefa563 set max tree width to 1200px (#16067)
new 7603ef6 Don't fail to log if we can't redact something (#16118)
new c6313e4 Fix Orphaned tasks stuck in CeleryExecutor as running (#16550)
new 1ca495c Fix tasks in an infinite slots pool were never scheduled
(#15247)
new e58a6a9 Add `passphrase` and `private_key` to default sensitive
fileld names (#16392)
new acc824f Fix templated default/example values in config ref docs
(#16442)
new 7b9dd0b add num_runs query param for tree refresh (#16437)
new c3bc645 Validate retries value on init for better errors (#16415)
new 4c06aae Clean Markdown with dedent to respect indents (#16414)
new b578120 Fix normalize-url vulnerability (#16375)
new fb62867 Make task ID on legend have enough width and width of line
chart to be 100%. (#15915)
new 19468d9 Queue tasks with higher priority and earlier execution_date
first. (#15210)
new 77060cd Support remote logging in elasticsearch with filebeat 7
(#14625)
new dbf3064 Make REST API List DAGs endpoint consistent with UI/CLI
behaviour (#16318)
new 5f478ec Don't show stale Serialized DAGs if they are deleted in DB
(#16368)
new e22b84d Adding `only_active` parameter to /dags endpoint (#14306)
new 777fd9b Correctly handle None returns from Query.scalar() (#16345)
new 215492d Tree View UI for larger DAGs & more consistent spacing in
Tree View (#16522)
new 7c094fa Backfill: Don't create a DagRun if no tasks match task regex
(#16461)
new 4c37aea Switch to built-in data structures in SecretsMasker (#16424)
new 6a5e676 Avoid recursing too deep when redacting logs (#16491)
new 8813c3d Allow null value for operator field in task_instance
schema(REST API) (#16516)
new e32f22a Fix unsuccessful KubernetesPod final_state call when
`is_delete_operator_pod=True` (#15490)
new 446e66b Fix DAG run state not updated while DAG is paused (#16343)
new 8114542 Fix Dag Details start date bug (#16206)
new fc30a4c Fix CLI connections import and migrate logic from secrets to
Connection model (#15425)
new c7a3977 Ensure that `dag_run.conf` is a dict (#15057)
new 46cfeee Add back-compat layer to clear_task_instances (#16582)
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 (abc86c4)
\
N -- N -- N refs/heads/v2-1-test (46cfeee)
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 38 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:
UPDATING.md | 11 +-
airflow/api_connexion/endpoints/dag_endpoint.py | 17 +-
airflow/api_connexion/openapi/v1.yaml | 12 +
airflow/api_connexion/schemas/dag_schema.py | 13 +
airflow/cli/commands/connection_command.py | 29 +-
airflow/cli/commands/dag_command.py | 4 +
airflow/config_templates/airflow_local_settings.py | 4 +
airflow/config_templates/config.yml | 14 +
airflow/config_templates/default_airflow.cfg | 6 +
airflow/configuration.py | 2 +-
airflow/executors/celery_executor.py | 4 +-
airflow/jobs/local_task_job.py | 15 +
airflow/jobs/scheduler_job.py | 1 +
airflow/models/baseoperator.py | 8 +
airflow/models/connection.py | 6 +-
airflow/models/dag.py | 6 +
airflow/models/dagbag.py | 11 +-
airflow/models/pool.py | 6 +-
airflow/models/serialized_dag.py | 10 +-
airflow/models/taskinstance.py | 15 +-
.../cncf/kubernetes/operators/kubernetes_pod.py | 25 +-
.../cncf/kubernetes/utils/pod_launcher.py | 7 +-
.../providers/elasticsearch/log/es_task_handler.py | 20 +-
airflow/typing_compat.py | 3 +-
airflow/utils/log/secrets_masker.py | 70 +-
airflow/www/api/experimental/endpoints.py | 6 +
airflow/www/package.json | 4 +-
airflow/www/static/js/tree.js | 6 +-
airflow/www/templates/airflow/dag_details.html | 15 +-
airflow/www/templates/airflow/tree.html | 5 +
airflow/www/templates/airflow/trigger.html | 2 +-
airflow/www/utils.py | 5 +-
airflow/www/views.py | 41 +-
airflow/www/yarn.lock | 1027 +++++++-------------
docs/conf.py | 14 +-
kubernetes_tests/test_kubernetes_pod_operator.py | 10 +-
.../test_kubernetes_pod_operator_backcompat.py | 6 +-
tests/api_connexion/endpoints/test_dag_endpoint.py | 103 +-
.../endpoints/test_dag_run_endpoint.py | 20 +
.../endpoints/test_task_instance_endpoint.py | 9 +-
tests/api_connexion/schemas/test_dag_schema.py | 5 +
tests/cli/commands/test_connection_command.py | 66 +-
tests/core/test_core.py | 46 +
tests/executors/test_celery_executor.py | 2 +
tests/jobs/test_local_task_job.py | 42 +-
tests/jobs/test_scheduler_job.py | 194 ++++
tests/models/test_dagbag.py | 31 +-
tests/models/test_pool.py | 4 +-
.../kubernetes/operators/test_kubernetes_pod.py | 11 +-
.../elasticsearch/log/test_es_task_handler.py | 61 +-
tests/utils/log/test_secrets_masker.py | 16 -
tests/www/api/experimental/test_endpoints.py | 24 +-
tests/www/test_utils.py | 36 +
tests/www/views/test_views_trigger_dag.py | 11 +
54 files changed, 1288 insertions(+), 853 deletions(-)
