This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch v2-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from 178dde3 By default PIP will install all packages in .local folder
(#14125)
new ac43056 Note that the DB must be using UTF-8 (#14742)
new f4cc5c5 Fix running child tasks in a subdag after clearing a
successful subdag (#14776)
new b583736 [AIRFLOW-6076] fix dag.cli() KeyError (#13647)
new 04ae0f6 Add more flexibility with FAB menu links (#13903)
new 118f86c Speed up clear_task_instances by doing a single sql delete
for TaskReschedule (#14048)
new 9d91058 Fix typos in concept docs (#14130)
new 472077e [AIRFLOW-7044] Host key can be specified via SSH connection
extras. (#12944)
new 05326e2 Sync DB Migrations in Master with 2.0.1 (#14155)
new 76be86e Log migrations info in consistent way (#14158)
new 8c95675 Make TaskInstance.pool_slots not nullable with a default of 1
(#14406)
new 7156d6c Rename last_scheduler_run into last_parsed_time, and ensure
it's updated in DB (#14581)
new 7790b2f Use `Lax` for `cookie_samesite` when empty string is passed
(#14183)
new 1858a94 Fix comparison dagTZ with localTZ (#14204)
new 36ff9c5 Fix indentation in code block in Taskflow API doc (#14241)
new 3f36fa9 Make airflow dags show command display TaskGroup (#14269)
new 44a261a Fix bug allowing task instances to survive when
dagrun_timeout is exceeded (#14321)
new 6dd7559 Scheduler should not fail when invalid executor_config is
passed (#14323)
new 0cb2a96 BugFix: Fix taskInstance API call fails if a task is removed
from running DAG (#14381)
new 040f7d8 Fix crash when user clicks on "Task Instance Details" caused
by start_date being None (#14416)
new 041c9d2 BugFix: Serialize max_retry_delay as a timedelta (#14436)
new 97d98bb Gracefully handle missing start_date and end_date for DagRun
(#14452)
new 99f1022 Fix statsd metrics not sending when using daemon mode (#14454)
new 62725ce Fix logging error with task error when JSON logging is
enabled (#14456)
new 5dd51dc Bugfix: Fix wrong output of tags and owners in dag detail API
endpoint (#14490)
new 87c26b4 BugFix: TypeError in monitor_pod (#14513)
new 051d239 Add plain format output to cli tables (#14546)
new a156053 BugFix: fix DAG doc display (especially for TaskFlow DAGs)
(#14564)
new bfe57d3 Bugfix: Plugins endpoint was unauthenticated (#14570)
new d6b40e2 Replace Graph View Screenshot to show Auto-refresh (#14571)
new 0fc6ca3 Default to Celery Task model when backend model does not
exist (#14612)
new b175785 Bump version to match node dependency (#14624)
new 3a0fb37 Remember expanded task groups in localStorage (#14661)
new f395cd8 Update Flask-AppBuilder dependency to allow 3.2 (and all 3.x
series) (#14665)
new 654248e Fix minor issues in 'Concepts' doc (#14679)
new ecd3e3c Webserver: Allow Filtering TaskInstances by queued_dttm
(#14708)
new 59afddd Fix KubernetesExecutor issue with deleted pending pods
(#14810)
new 6ae0cb0 Pin SQLAlchemy to <1.4 due to breakage of sqlalchemy-utils
(#14812)
new eab3b9e Suggest using $http_host instead of $host (#14814)
new 8bdfe07 Bump Redoc to resolve vulnerability in sub-dependency (#14608)
new 71b44a2 fix lossing duration < 1 secs in tree (#13537)
new 9f33dfb Fix tests for all urllib versions with only '&' as separator
(#14710)
new 831c7ec Webserver: Sanitize string passed to origin param (#14738)
The 42 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 | 2 +-
airflow/api_connexion/openapi/v1.yaml | 1 +
airflow/api_connexion/schemas/dag_schema.py | 36 +-
airflow/cli/cli_parser.py | 39 +-
airflow/cli/simple_table.py | 11 +
airflow/executors/celery_executor.py | 4 +-
airflow/executors/kubernetes_executor.py | 14 +-
airflow/jobs/scheduler_job.py | 14 +-
airflow/kubernetes/pod_launcher.py | 7 +-
...e42bb497a22_rename_last_scheduler_run_column.py | 65 +++
...da_increase_size_of_connection_extra_field_.py} | 24 +-
...8c147f_remove_can_read_permission_on_config_.py | 6 +
.../8646922c8a04_change_default_pool_slots_to_1.py | 93 ++++
airflow/models/baseoperator.py | 9 +-
airflow/models/connection.py | 2 +-
airflow/models/dag.py | 17 +-
airflow/models/dagrun.py | 6 +
airflow/models/taskinstance.py | 47 +-
airflow/providers/sftp/hooks/sftp.py | 6 +
airflow/providers/ssh/hooks/ssh.py | 18 +-
airflow/serialization/schema.json | 1 +
airflow/serialization/serialized_objects.py | 2 +-
airflow/stats.py | 27 +-
airflow/utils/dot_renderer.py | 120 +++-
airflow/utils/state.py | 1 +
airflow/www/app.py | 12 +-
airflow/www/extensions/init_views.py | 9 +-
airflow/www/package.json | 2 +-
airflow/www/security.py | 9 +-
airflow/www/static/js/task-instances.js | 2 +-
airflow/www/templates/airflow/graph.html | 117 +++-
airflow/www/utils.py | 2 +
airflow/www/views.py | 32 +-
airflow/www/yarn.lock | 616 ++++++---------------
.../connections/ssh.rst | 6 +-
docs/apache-airflow/concepts.rst | 32 +-
docs/apache-airflow/howto/run-behind-proxy.rst | 4 +-
docs/apache-airflow/howto/set-up-database.rst | 9 +
docs/apache-airflow/img/graph.png | Bin 118674 -> 225347 bytes
docs/apache-airflow/plugins.rst | 19 +-
docs/apache-airflow/tutorial_taskflow_api.rst | 2 +-
docs/apache-airflow/usage-cli.rst | 1 +
docs/conf.py | 2 +-
docs/spelling_wordlist.txt | 2 +
setup.cfg | 5 +-
tests/api_connexion/endpoints/test_dag_endpoint.py | 28 +-
.../endpoints/test_task_instance_endpoint.py | 31 ++
tests/api_connexion/schemas/test_dag_schema.py | 3 +-
tests/cli/test_cli_parser.py | 26 +
tests/core/test_stats.py | 1 +
tests/executors/test_kubernetes_executor.py | 112 ++++
tests/jobs/test_scheduler_job.py | 63 +++
tests/kubernetes/test_pod_launcher.py | 18 +-
tests/models/test_cleartasks.py | 47 +-
tests/models/test_dag.py | 70 ++-
tests/models/test_taskinstance.py | 33 ++
tests/plugins/test_plugin.py | 12 +-
tests/plugins/test_plugins_manager.py | 27 +-
tests/providers/sftp/hooks/test_sftp.py | 41 +-
tests/providers/ssh/hooks/test_ssh.py | 93 ++++
tests/serialization/test_dag_serialization.py | 4 +
tests/utils/test_dot_renderer.py | 101 +++-
tests/www/test_app.py | 6 +
tests/www/test_utils.py | 11 +
tests/www/test_views.py | 33 +-
65 files changed, 1570 insertions(+), 645 deletions(-)
create mode 100644
airflow/migrations/versions/2e42bb497a22_rename_last_scheduler_run_column.py
copy
airflow/migrations/versions/{fe461863935f_increase_length_for_connection_password.py
=> 449b4072c2da_increase_size_of_connection_extra_field_.py} (76%)
create mode 100644
airflow/migrations/versions/8646922c8a04_change_default_pool_slots_to_1.py