This is an automated email from the ASF dual-hosted git repository. kaxilnaik pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git.
from b06d528 Don't cache Google Secret Manager client (#17539) add ec5b4fe AIP-40: Add Deferrable "Async" Tasks (#15389) No new revisions were added by this update. Summary of changes: .pre-commit-config.yaml | 3 +- airflow/api_connexion/openapi/v1.yaml | 2 + airflow/cli/cli_parser.py | 20 ++ airflow/cli/commands/standalone_command.py | 10 +- .../{kerberos_command.py => triggerer_command.py} | 28 +- .../hooks/test_sqs.py => airflow/compat/asyncio.py | 22 +- airflow/config_templates/config.yml | 17 + airflow/config_templates/default_airflow.cfg | 7 + airflow/exceptions.py | 34 +- airflow/jobs/scheduler_job.py | 38 ++- airflow/jobs/triggerer_job.py | 380 +++++++++++++++++++++ ...54bebd308c5f_add_trigger_table_and_task_info.py | 69 ++++ airflow/models/__init__.py | 1 + airflow/models/baseoperator.py | 20 +- airflow/models/dagrun.py | 11 +- airflow/models/taskinstance.py | 137 +++++++- airflow/models/trigger.py | 195 +++++++++++ airflow/sensors/date_time.py | 20 ++ airflow/sensors/time_delta.py | 21 ++ airflow/sensors/time_sensor.py | 22 ++ airflow/settings.py | 1 + .../zendesk/hooks => airflow/triggers}/__init__.py | 0 airflow/triggers/base.py | 98 ++++++ airflow/triggers/temporal.py | 76 +++++ airflow/triggers/testing.py | 52 +++ airflow/utils/sqlalchemy.py | 47 ++- airflow/utils/state.py | 8 +- airflow/www/static/css/graph.css | 4 + airflow/www/static/css/main.css | 4 + airflow/www/static/css/tree.css | 4 + airflow/www/static/js/graph.js | 1 + airflow/www/utils.py | 25 +- airflow/www/views.py | 2 + docs/apache-airflow/concepts/deferring.rst | 163 +++++++++ docs/apache-airflow/concepts/index.rst | 1 + docs/apache-airflow/concepts/smart-sensors.rst | 6 + docs/apache-airflow/concepts/tasks.rst | 1 + .../howto/customize-state-colors-ui.rst | 1 + docs/apache-airflow/migrations-ref.rst | 4 +- docs/spelling_wordlist.txt | 6 + setup.py | 1 + ...ersion_command.py => test_triggerer_command.py} | 27 +- tests/core/test_config_templates.py | 1 + tests/jobs/test_scheduler_job.py | 48 +++ tests/jobs/test_triggerer_job.py | 326 ++++++++++++++++++ tests/models/test_taskinstance.py | 4 + tests/models/test_trigger.py | 123 +++++++ tests/test_utils/db.py | 4 + tests/triggers/test_temporal.py | 84 +++++ tests/www/views/test_views_base.py | 3 +- 50 files changed, 2126 insertions(+), 56 deletions(-) copy airflow/cli/commands/{kerberos_command.py => triggerer_command.py} (64%) copy tests/providers/amazon/aws/hooks/test_sqs.py => airflow/compat/asyncio.py (68%) create mode 100644 airflow/jobs/triggerer_job.py create mode 100644 airflow/migrations/versions/54bebd308c5f_add_trigger_table_and_task_info.py create mode 100644 airflow/models/trigger.py copy {tests/providers/zendesk/hooks => airflow/triggers}/__init__.py (100%) create mode 100644 airflow/triggers/base.py create mode 100644 airflow/triggers/temporal.py create mode 100644 airflow/triggers/testing.py create mode 100644 docs/apache-airflow/concepts/deferring.rst copy tests/cli/commands/{test_version_command.py => test_triggerer_command.py} (60%) create mode 100644 tests/jobs/test_triggerer_job.py create mode 100644 tests/models/test_trigger.py create mode 100644 tests/triggers/test_temporal.py