You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2021/08/11 19:33:56 UTC
[airflow] branch main updated (b06d528 -> ec5b4fe)
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