You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/03/01 11:40:58 UTC
[airflow] branch main updated (9e67692 -> 33edeb2)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from 9e67692 add celery.task_timeout_error metric (#21602)
add 33edeb2 Feature: Add invoke lambda function operator (#21686)
No new revisions were added by this update.
Summary of changes:
.../{example_sns.py => example_lambda.py} | 30 +++---
.../providers/amazon/aws/hooks/lambda_function.py | 91 +++++++++++++----
.../providers/amazon/aws/operators/aws_lambda.py | 102 +++++++++++++++++++
airflow/providers/amazon/provider.yaml | 5 +
.../operators/{sns.rst => lambda.rst} | 33 +++----
.../amazon/aws/hooks/test_lambda_function.py | 6 +-
.../providers/amazon/aws/operators/test_lambda.py | 109 +++++++++++++++++++++
7 files changed, 327 insertions(+), 49 deletions(-)
copy airflow/providers/amazon/aws/example_dags/{example_sns.py => example_lambda.py} (55%)
create mode 100644 airflow/providers/amazon/aws/operators/aws_lambda.py
copy docs/apache-airflow-providers-amazon/operators/{sns.rst => lambda.rst} (50%)
create mode 100644 tests/providers/amazon/aws/operators/test_lambda.py