This is an automated email from the ASF dual-hosted git repository.
bbovenzi pushed a change to branch mapped-instance-actions
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 92f116d7d3 Fix gantt/graph modal
discard c4f8d93a65 Readd mapped instance table selection
discard 0e591c44ae Allow bulk mapped task actions
discard 80fd8a513f fixup! fixup! fixup! fixup! fixup! fixup! Allow
marking/clearing mapped taskinstances from the UI
discard 916ae06eb8 fixup! fixup! fixup! fixup! fixup! Allow marking/clearing
mapped taskinstances from the UI
discard 3b1c5a4314 fixup! fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
discard 5dfc9ec156 add tests
discard 8341236dd6 fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
discard d8c30ce0e4 fixup! fixup! Allow marking/clearing mapped taskinstances
from the UI
discard a5910018aa fixup! Allow marking/clearing mapped taskinstances from the
UI
discard 79be08d2d0 Allow marking/clearing mapped taskinstances from the UI
add 44c0edb34e Add option `--skip-init` to db reset command (#22989)
add a68323cc72 Base run details header on interval start (#22999)
add ddb5d9b4a2 Add doc and sample dag for S3CopyObjectOperator and
S3DeleteObjectsOperator (#22959)
add d81703c577 Add k8s container's error message in airflow exception
(#22871)
add 3ac1be2027 Skip log template sync if table doesn't exist (#22993)
add 26e09dffe5 Add dangling rows check for TaskInstance references (#22924)
add 5d1270c32b Resolve XComArgs before trying to unmap MappedOperators
(#22975)
add 84177a6d69 Update ImportError items instead of deleting and recreating
them (#22928)
add 1911c92110 Give useful repr to _LazyXComAccess class (#23002)
add 22908d217d Note that value received in reduce is not a list (#23006)
add 52066d4248 Don't add planned tasks for legacy DAG runs (#23007)
add 95046666eb Fix download logs from Grid/graph view (#23009)
add 90a4c87f96 Change trigger dropdown left position (#23013)
add 52b724e147 Fix some weird English in `create_dagrun` exceptions
(#23003)
add ea1ae1963e Fix cancel_on_kill after execution timeout for
DataprocSubmitJobOperator (#22955)
add 815482f86c Change `ExternalTaskMarker` to `EmptyOperator` (#23010)
add 70049f19e4 Fix TaskFail queries in views after run_id migration
(#23008)
add 4de4c9356e Make sure all mapped nodes are updated. (#23019)
add 6d6ac2b2bc Purge duplicates from TaskFail prior to 2.3 upgrade (#22769)
add 6544347730 Add `2.3.0b1` to issue template (#23024)
add fbfbc26a7a Update gcs_to_local.rst (#23026)
add c92954418a Breeze is installed via pipx in CI (#23023)
add c36bcc4c06 Upgrade to support Google Ads v10 (#22965)
add 6cd1437987 Allow marking/clearing mapped taskinstances from the UI
add 729f9c3f43 fixup! Allow marking/clearing mapped taskinstances from the
UI
add 5fc16f2a0c fixup! fixup! Allow marking/clearing mapped taskinstances
from the UI
add 826c650dbe fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
add bdfe553c4f add tests
add bb8c9523a3 fixup! fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
add c931816645 fixup! fixup! fixup! fixup! fixup! Allow marking/clearing
mapped taskinstances from the UI
add 3dd0ef3de6 fixup! fixup! fixup! fixup! fixup! fixup! Allow
marking/clearing mapped taskinstances from the UI
add 0b4c4857da Apply suggestions from code review
add 98abe5fcb8 fixup! Apply suggestions from code review
add b3cae77218 Include message in graph errors (#23021)
add 8cf1cb3e04 Bump async from 2.6.3 to 2.6.4 in /airflow/ui (#23034)
add 8e75e23497 Allow re-use of decorated tasks (#22941)
add 3a2eb961ca Fix tests using has_calls to use assert_has_calls. (#23001)
add 1f8d0c3249 Merge branch 'main' into clearing-and-marking-mapped-task
new 02f3f6b94b Refactor to straighten up types
new 79f13c56b0 Allow bulk mapped task actions
new 6c87f0cdc1 Readd mapped instance table selection
new c0d33a6caa Fix gantt/graph modal
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 (92f116d7d3)
\
N -- N -- N refs/heads/mapped-instance-actions (c0d33a6caa)
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 4 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:
.github/ISSUE_TEMPLATE/airflow_bug_report.yml | 1 +
.../airflow_helmchart_bug_report.yml | 1 +
.../airflow_providers_bug_report.yml | 1 +
.github/workflows/build-images.yml | 4 +-
.github/workflows/ci.yml | 55 ++---
Dockerfile | 3 +-
Dockerfile.ci | 3 +-
airflow/api/common/mark_tasks.py | 28 ++-
airflow/cli/cli_parser.py | 8 +-
airflow/cli/commands/db_command.py | 7 +-
airflow/dag_processing/processor.py | 20 +-
airflow/decorators/base.py | 48 +++-
airflow/jobs/local_task_job.py | 5 -
airflow/models/abstractoperator.py | 22 +-
airflow/models/dag.py | 154 ++++++------
airflow/models/mappedoperator.py | 75 ++++--
airflow/models/taskfail.py | 12 +
airflow/models/taskinstance.py | 48 ++--
airflow/models/xcom_arg.py | 10 +-
.../{example_s3_bucket.py => example_s3.py} | 26 ++-
airflow/providers/amazon/aws/operators/s3.py | 8 +
.../cncf/kubernetes/operators/kubernetes_pod.py | 13 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 9 +
airflow/providers/google/CHANGELOG.rst | 16 ++
airflow/providers/google/ads/hooks/ads.py | 23 +-
.../providers/google/cloud/operators/dataproc.py | 16 +-
airflow/sensors/external_task.py | 4 +-
airflow/ui/yarn.lock | 6 +-
airflow/utils/db.py | 259 ++++++++++++++++-----
airflow/www/static/css/main.css | 2 +-
airflow/www/static/js/graph.js | 12 +-
airflow/www/static/js/tree/details/Header.jsx | 2 +-
.../js/tree/details/content/taskInstance/Logs.jsx | 2 +-
airflow/www/views.py | 99 ++++----
docker_tests/requirements.txt | 3 +
.../operators/s3.rst | 47 +++-
docs/apache-airflow-providers-google/index.rst | 2 +-
.../operators/transfer/gcs_to_local.rst | 2 +-
.../concepts/dynamic-task-mapping.rst | 46 +++-
docs/apache-airflow/tutorial_taskflow_api.rst | 58 +++++
scripts/ci/images/ci_run_docker_tests.py | 13 +-
.../stop_tmux_airflow.sh => ci/install_breeze.sh} | 11 +-
setup.cfg | 4 +-
setup.py | 5 +-
tests/cli/commands/test_db_command.py | 7 +-
tests/dag_processing/test_processor.py | 28 +++
tests/decorators/test_python.py | 97 ++++++++
tests/models/test_baseoperator.py | 43 ++++
tests/models/test_dag.py | 2 +-
tests/models/test_taskinstance.py | 2 +
.../kubernetes/operators/test_kubernetes_pod.py | 2 +-
tests/providers/google/ads/operators/test_ads.py | 2 +-
.../google/cloud/hooks/test_cloud_memorystore.py | 42 +++-
tests/providers/google/cloud/hooks/test_looker.py | 2 +-
.../google/cloud/operators/test_dataproc.py | 29 +++
.../google/cloud/transfers/test_calendar_to_gcs.py | 36 ++-
tests/utils/test_db.py | 12 +-
tests/www/views/test_views_tasks.py | 47 +++-
58 files changed, 1118 insertions(+), 426 deletions(-)
rename airflow/providers/amazon/aws/example_dags/{example_s3_bucket.py =>
example_s3.py} (85%)
create mode 100644 docker_tests/requirements.txt
copy scripts/{in_container/stop_tmux_airflow.sh => ci/install_breeze.sh} (80%)
