This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a change to branch v2-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 679bd6afaf Add cache_ok flag to sqlalchemy TypeDecorators. (#24499)
new 40f16612f9 Fix StatD timing metric units (#21106)
new 7b548b0e69 ExternalTaskSensor respects soft_fail if the external task
enters a failed_state (#23647)
new 6ca7f3a317 Fix doc description of [core] parallelism config setting
(#23768)
new 4081a65b77 Remove special serde logic for mapped op_kwargs (#23860)
new 46d26c76af Drop Python 3.6 compatibility objects/modules (#24048)
new 4284d03e98 Handle occasional deadlocks in trigger with retries (#24071)
new 065cd19de4 Unify return_code interface for task runner (#24093)
new 49fc732db3 scheduleinterval nullable true added in openapi (#24253)
new d3366fcdde Fix bugs in URI constructor for MySQL connection (#24320)
new b9fb473eb3 DebugExecutor use ti.run() instead of ti._run_raw_task
(#24357)
new 7a11046ca1 Mask secrets in stdout for 'airflow tasks test' (#24362)
new 2b9f6d0512 Add missing types to FSHook (#24470)
new 465834bfbe Fix typo (#24568)
new 51c58c0c68 Move fallible ti.task.dag assignment back inside try/except
block (#24533) (#24592)
new 691ceab953 Fix timestamp defaults for sensorinstance (#24638)
new 774f8bc67c Update the release note
The 16 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:
RELEASE_NOTES.rst | 15 +++
airflow/api_connexion/openapi/v1.yaml | 1 +
airflow/cli/commands/task_command.py | 10 +-
airflow/compat/asyncio.py | 28 ------
airflow/config_templates/config.yml | 7 +-
airflow/config_templates/default_airflow.cfg | 7 +-
airflow/dag_processing/manager.py | 6 +-
airflow/decorators/base.py | 10 +-
airflow/executors/debug_executor.py | 2 +-
airflow/hooks/filesystem.py | 4 +-
airflow/jobs/triggerer_job.py | 5 +-
.../versions/0001_1_5_0_current_schema.py | 2 +-
.../0065_2_0_0_update_schema_for_smart_sensor.py | 4 +-
.../0103_2_3_0_add_callback_request_table.py | 2 +-
airflow/models/connection.py | 10 +-
airflow/models/dag.py | 6 +-
airflow/models/mappedoperator.py | 1 +
airflow/models/sensorinstance.py | 4 +-
airflow/models/taskmixin.py | 2 +-
airflow/models/trigger.py | 9 +-
.../providers/elasticsearch/log/es_task_handler.py | 7 +-
airflow/sensors/external_task.py | 29 +++++-
airflow/sensors/smart_sensor.py | 9 +-
airflow/serialization/serialized_objects.py | 29 +-----
airflow/task/task_runner/base_task_runner.py | 2 +-
airflow/task/task_runner/cgroup_task_runner.py | 3 +-
airflow/typing_compat.py | 9 --
airflow/utils/log/file_task_handler.py | 10 +-
airflow/utils/log/secrets_masker.py | 42 +++++---
tests/cli/commands/test_connection_command.py | 6 +-
tests/cli/commands/test_task_command.py | 40 +++++---
tests/dag_processing/test_manager.py | 6 +-
.../dags/{test_missing_owner.py => test_sensor.py} | 20 ++--
tests/executors/test_debug_executor.py | 4 +-
tests/hooks/test_dbapi.py | 106 +++++++++++++++++++++
tests/jobs/test_backfill_job.py | 58 +++++++----
tests/secrets/test_local_filesystem.py | 4 +-
tests/sensors/test_external_task_sensor.py | 57 +++++++++--
tests/sensors/test_smart_sensor_operator.py | 23 +++++
tests/serialization/test_dag_serialization.py | 29 +++---
tests/triggers/test_temporal.py | 5 +-
tests/utils/log/test_secrets_masker.py | 23 ++++-
42 files changed, 443 insertions(+), 213 deletions(-)
delete mode 100644 airflow/compat/asyncio.py
copy tests/dags/{test_missing_owner.py => test_sensor.py} (66%)