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 9a2a5b0695 Fix print message in release_candidate_command.py (#31910)
add a81ac70b33 Add deferrable mode to PubsubPullSensor (#31284)
No new revisions were added by this update.
Summary of changes:
airflow/providers/google/cloud/hooks/pubsub.py | 140 ++++++++++++++++++++-
airflow/providers/google/cloud/sensors/pubsub.py | 49 +++++++-
airflow/providers/google/cloud/triggers/pubsub.py | 126 +++++++++++++++++++
airflow/providers/google/provider.yaml | 3 +
.../operators/cloud/pubsub.rst | 8 ++
tests/providers/google/cloud/hooks/test_pubsub.py | 51 +++++++-
.../providers/google/cloud/sensors/test_pubsub.py | 50 +++++++-
.../providers/google/cloud/triggers/test_pubsub.py | 61 +++++++++
.../google/cloud/pubsub/example_pubsub.py | 2 +-
...mple_pubsub.py => example_pubsub_deferrable.py} | 69 ++--------
10 files changed, 490 insertions(+), 69 deletions(-)
create mode 100644 airflow/providers/google/cloud/triggers/pubsub.py
create mode 100644 tests/providers/google/cloud/triggers/test_pubsub.py
copy tests/system/providers/google/cloud/pubsub/{example_pubsub.py =>
example_pubsub_deferrable.py} (60%)