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 db5a08acee Fix gantt/graph modal
discard f348c855ab Readd mapped instance table selection
discard 8133556392 Allow bulk mapped task actions
discard 95a0a2e212 fixup! fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
discard da3ebb3e20 add tests
discard 3e88fb90a9 fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
discard 1a3dedf323 fixup! fixup! Allow marking/clearing mapped taskinstances
from the UI
discard 781cd47aa4 fixup! Allow marking/clearing mapped taskinstances from the
UI
discard b72f9dafab Allow marking/clearing mapped taskinstances from the UI
add 069666cc0b Remove duplicate Apache License line in `ci.yml` (#22960)
add e5dd6fdcfd Bug Fix for `apache-airflow-providers-jenkins`
`JenkinsJobTriggerOperator` (#22802)
add de7a92a73b Hide pagination when data is a single page (#22963)
add 70065e6569 Fix screenshot generation for dumb terminal (#22962)
add 4148883ee3 Deprecate `DummyOperator` in favor of `EmptyOperator`
(#22832)
add e09b4f144d Refactor airbyte provider tests to use assert_has_calls
(#22951)
add a0f7e61497 Allow DagParam to hold falsy values (#22964)
add aa317d92ea Fix select * query xcom push for BigQueryGetDataOperator
(#22936)
add 7331eefc39 Add template support for external_task_ids. (#22809)
add 0cd8833df7 Support glob syntax in ``.airflowignore`` files (#21392)
(#22051)
add 2f051e303f Add max width to task group tooltips (#22978)
add 40831144be Prepare for RC2 release of March Databricks provider
(#22979)
add 7fe97fb86f Update tree doc references to grid (#22966)
add 55aa701503 Add no_status to state priority list (#22985)
add 1eab1ec74c Correctly show rendered templates for mapped task
instances. (#22984)
add 3c0ad4af31 Support importing connections from files with ".yml"
extension (#22872)
add 165945250b Fail if task does not push XCom for downstream (#22954)
add 5ba2f0dcb6 Add a clipboard button to grid details (#22988)
add 0cbf2c752d Drop "airflow moved" tables in command `db reset` (#22990)
add a801ea3927 es new system tests (#22811)
add bab740c0a4 Fix trigger event payload is not persisted in db (#22944)
add d0a880d069 Fix tooltip for mapped tasks (#22994)
add 49e336ae03 Replace usage of `DummyOperator` with `EmptyOperator`
(#22974)
add 9a623e94cb migrate system test gcs_to_bigquery into new design (#22753)
add d7993dca2f formatting fix (#22688)
add 79be08d2d0 Allow marking/clearing mapped taskinstances from the UI
add a5910018aa fixup! Allow marking/clearing mapped taskinstances from the
UI
add d8c30ce0e4 fixup! fixup! Allow marking/clearing mapped taskinstances
from the UI
add 8341236dd6 fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
add 5dfc9ec156 add tests
add 3b1c5a4314 fixup! fixup! fixup! fixup! Allow marking/clearing mapped
taskinstances from the UI
add 916ae06eb8 fixup! fixup! fixup! fixup! fixup! Allow marking/clearing
mapped taskinstances from the UI
add 80fd8a513f fixup! fixup! fixup! fixup! fixup! fixup! Allow
marking/clearing mapped taskinstances from the UI
new 0e591c44ae Allow bulk mapped task actions
new c4f8d93a65 Readd mapped instance table selection
new 92f116d7d3 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 (db5a08acee)
\
N -- N -- N refs/heads/mapped-instance-actions (92f116d7d3)
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 3 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/workflows/ci.yml | 1 -
README.md | 4 +-
airflow/api/common/mark_tasks.py | 3 +-
airflow/cli/commands/connection_command.py | 25 +++
airflow/config_templates/config.yml | 8 +
airflow/config_templates/default_airflow.cfg | 4 +
airflow/configuration.py | 1 +
airflow/decorators/base.py | 2 +-
airflow/example_dags/example_bash_operator.py | 4 +-
.../example_branch_datetime_operator.py | 18 +-
.../example_branch_day_of_week_operator.py | 10 +-
airflow/example_dags/example_branch_labels.py | 16 +-
airflow/example_dags/example_branch_operator.py | 12 +-
.../example_branch_operator_decorator.py | 12 +-
.../example_branch_python_dop_operator_3.py | 14 +-
.../example_external_task_marker_dag.py | 4 +-
airflow/example_dags/example_latest_only.py | 4 +-
.../example_latest_only_with_trigger.py | 10 +-
airflow/example_dags/example_nested_branch_dag.py | 16 +-
.../example_dags/example_short_circuit_operator.py | 10 +-
airflow/example_dags/example_skip_dag.py | 16 +-
airflow/example_dags/example_subdag_operator.py | 8 +-
airflow/example_dags/example_task_group.py | 16 +-
.../example_dags/example_task_group_decorator.py | 10 +-
.../example_time_delta_sensor_async.py | 4 +-
airflow/example_dags/example_xcomargs.py | 4 +-
airflow/example_dags/subdags/subdag.py | 4 +-
airflow/exceptions.py | 7 +
airflow/models/abstractoperator.py | 4 +-
airflow/models/baseoperator.py | 10 +-
airflow/models/dag.py | 23 +--
airflow/models/dagbag.py | 7 +-
airflow/models/dagrun.py | 8 +-
airflow/models/mappedoperator.py | 10 +-
airflow/models/param.py | 24 +--
airflow/models/taskinstance.py | 22 ++-
airflow/operators/dummy.py | 36 ++--
airflow/operators/dummy_operator.py | 18 +-
airflow/operators/{dummy.py => empty.py} | 9 +-
airflow/providers/databricks/CHANGELOG.rst | 8 +
.../dbt/cloud/example_dags/example_dbt_cloud.py | 10 +-
.../dingding/example_dags/example_dingding.py | 4 +-
.../providers/google/cloud/operators/bigquery.py | 8 +
.../jdbc/example_dags/example_jdbc_queries.py | 8 +-
.../jenkins/operators/jenkins_job_trigger.py | 18 +-
.../azure/example_dags/example_adf_run_pipeline.py | 10 +-
.../microsoft/winrm/example_dags/example_winrm.py | 8 +-
.../qubole/example_dags/example_qubole.py | 8 +-
airflow/secrets/local_filesystem.py | 5 +-
airflow/sensors/external_task.py | 2 +-
airflow/serialization/serialized_objects.py | 13 +-
airflow/utils/db.py | 11 ++
airflow/utils/file.py | 181 +++++++++++++++----
airflow/www/static/css/main.css | 1 +
airflow/www/static/js/tree/Clipboard.jsx | 63 +++++++
airflow/www/static/js/tree/InstanceTooltip.jsx | 60 +++----
airflow/www/static/js/tree/Table.jsx | 2 +
.../js/tree/details/content/dagRun/index.jsx | 3 +-
.../tree/details/content/taskInstance/Details.jsx | 5 +-
airflow/www/utils.py | 36 ++--
airflow/www/views.py | 26 +--
dev/provider_packages/prepare_provider_packages.py | 10 ++
.../commits.rst | 6 +-
.../connections/elasticsearch.rst | 6 +
.../operators/cloud/gcs.rst | 2 +-
docs/apache-airflow/concepts/dags.rst | 49 +++--
.../howto/dynamic-dag-generation.rst | 4 +-
docs/apache-airflow/img/grid.png | Bin 0 -> 347155 bytes
docs/apache-airflow/img/grid_instance_details.png | Bin 0 -> 287820 bytes
docs/apache-airflow/img/grid_mapped_task.png | Bin 0 -> 334409 bytes
docs/apache-airflow/img/grid_run_details.png | Bin 0 -> 243661 bytes
docs/apache-airflow/img/grid_task_group.png | Bin 0 -> 56287 bytes
.../img/task_manual_vs_scheduled.png | Bin 5806 -> 5686 bytes
docs/apache-airflow/img/tree.png | Bin 139707 -> 0 bytes
docs/apache-airflow/modules_management.rst | 13 +-
docs/apache-airflow/ui.rst | 33 +++-
.../extending/embedding-dags/test_dag.py | 8 +-
.../ci/pre_commit/pre_commit_breeze_cmd_line.py | 2 +
setup.cfg | 1 +
tests/api/common/test_delete_dag.py | 4 +-
tests/api_connexion/endpoints/test_dag_endpoint.py | 8 +-
.../endpoints/test_dag_run_endpoint.py | 6 +-
tests/api_connexion/endpoints/test_log_endpoint.py | 6 +-
.../api_connexion/endpoints/test_task_endpoint.py | 24 +--
.../api_connexion/endpoints/test_xcom_endpoint.py | 10 +-
.../schemas/test_task_instance_schema.py | 8 +-
tests/api_connexion/schemas/test_task_schema.py | 14 +-
tests/cli/commands/test_connection_command.py | 16 +-
tests/conftest.py | 14 +-
tests/core/test_core.py | 8 +-
tests/core/test_stats.py | 62 +++----
tests/dag_processing/test_processor.py | 6 +-
tests/dags/.airflowignore | 2 +
tests/dags/.airflowignore_glob | 20 +++
tests/dags/subdir2/.airflowignore_glob | 2 +
.../dags/subdir2/subdir3/test_nested_dag.py | 3 +-
tests/dags/test_dag_with_no_tags.py | 4 +-
tests/dags/test_double_trigger.py | 4 +-
tests/dags/test_example_bash_operator.py | 4 +-
tests/dags/test_invalid_cron.py | 4 +-
tests/dags/test_issue_1225.py | 20 +--
tests/dags/test_latest_runs.py | 4 +-
tests/dags/test_miscellaneous.py | 4 +-
tests/dags/test_missing_owner.py | 4 +-
tests/dags/test_on_failure_callback.py | 4 +-
tests/dags/test_on_kill.py | 4 +-
...nly_dummy_tasks.py => test_only_empty_tasks.py} | 16 +-
tests/dags/test_prev_dagrun_dep.py | 8 +-
tests/dags/test_scheduler_dags.py | 8 +-
tests/dags/test_subdag.py | 8 +-
tests/dags/test_with_non_default_owner.py | 4 +-
.../dags_with_system_exit/b_test_scheduler_dags.py | 4 +-
tests/deprecated_classes.py | 6 +-
tests/jobs/test_backfill_job.py | 64 +++----
tests/jobs/test_local_task_job.py | 12 +-
tests/jobs/test_scheduler_job.py | 199 +++++++++++----------
tests/jobs/test_triggerer_job.py | 4 +-
tests/lineage/test_lineage.py | 16 +-
tests/models/test_cleartasks.py | 30 ++--
tests/models/test_dag.py | 163 ++++++++---------
tests/models/test_dagbag.py | 40 ++---
tests/models/test_dagrun.py | 74 ++++----
tests/models/test_pool.py | 14 +-
tests/models/test_skipmixin.py | 12 +-
tests/models/test_taskinstance.py | 114 +++++++-----
tests/models/test_timestamp.py | 4 +-
tests/models/test_trigger.py | 7 +-
tests/models/test_xcom.py | 6 +-
tests/operators/test_branch_operator.py | 8 +-
tests/operators/test_datetime.py | 6 +-
.../google/conftest.py => operators/test_dummy.py} | 8 +-
tests/operators/test_latest_only_operator.py | 12 +-
tests/operators/test_python.py | 14 +-
tests/operators/test_sql.py | 8 +-
tests/operators/test_subdag_operator.py | 12 +-
tests/operators/test_trigger_dagrun.py | 4 +-
tests/operators/test_weekday.py | 8 +-
tests/plugins/test_plugin_ignore.py | 46 ++++-
tests/providers/airbyte/hooks/test_airbyte.py | 14 +-
tests/providers/amazon/aws/hooks/test_sagemaker.py | 2 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 4 +-
.../amazon/aws/log/test_s3_task_handler.py | 4 +-
tests/providers/dingding/hooks/test_dingding.py | 4 +-
.../cloud/transfers/test_gcs_to_bigquery_system.py | 36 ----
tests/secrets/test_local_filesystem.py | 20 ++-
tests/sensors/test_base.py | 4 +-
tests/sensors/test_external_task_sensor.py | 59 +++++-
tests/sensors/test_smart_sensor_operator.py | 4 +-
tests/serialization/test_dag_serialization.py | 104 +++++++----
.../elasticsearch}/example_elasticsearch_query.py | 38 ++--
.../google/gcs}/example_gcs_to_bigquery.py | 38 +++-
tests/system/utils/__init__.py | 2 +-
.../deps/test_not_previously_skipped_dep.py | 20 +--
tests/ti_deps/deps/test_trigger_rule_dep.py | 14 +-
tests/utils/test_dag_cycle.py | 52 +++---
tests/utils/test_db.py | 21 ++-
tests/utils/test_dot_renderer.py | 16 +-
tests/utils/test_edgemodifier.py | 24 +--
tests/utils/test_file.py | 37 +++-
tests/utils/test_task_group.py | 140 +++++++--------
.../test_task_handler_with_custom_formatter.py | 4 +-
tests/www/views/test_views.py | 12 +-
tests/www/views/test_views_blocked.py | 4 +-
163 files changed, 1782 insertions(+), 1145 deletions(-)
copy airflow/operators/{dummy.py => empty.py} (88%)
create mode 100644 airflow/www/static/js/tree/Clipboard.jsx
create mode 100644 docs/apache-airflow/img/grid.png
create mode 100644 docs/apache-airflow/img/grid_instance_details.png
create mode 100644 docs/apache-airflow/img/grid_mapped_task.png
create mode 100644 docs/apache-airflow/img/grid_run_details.png
create mode 100644 docs/apache-airflow/img/grid_task_group.png
delete mode 100644 docs/apache-airflow/img/tree.png
create mode 100644 tests/dags/.airflowignore_glob
create mode 100644 tests/dags/subdir2/.airflowignore_glob
copy airflow/api/auth/__init__.py =>
tests/dags/subdir2/subdir3/test_nested_dag.py (97%)
rename tests/dags/{test_only_dummy_tasks.py => test_only_empty_tasks.py} (70%)
copy tests/{system/providers/google/conftest.py => operators/test_dummy.py}
(80%)
delete mode 100644
tests/providers/google/cloud/transfers/test_gcs_to_bigquery_system.py
copy {airflow/providers/elasticsearch/example_dags =>
tests/system/providers/elasticsearch}/example_elasticsearch_query.py (62%)
rename {airflow/providers/google/cloud/example_dags =>
tests/system/providers/google/gcs}/example_gcs_to_bigquery.py (69%)
