You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by vi...@apache.org on 2025/02/21 23:03:05 UTC

(airflow) branch common-msgQ updated (12824c60a9e -> ff6f5c857af)

This is an automated email from the ASF dual-hosted git repository.

vincbeck pushed a change to branch common-msgQ
in repository https://gitbox.apache.org/repos/asf/airflow.git


    from 12824c60a9e Merge branch 'main' into common-msgQ
     add 536cc79a776 Rename `msgq` to `messaging`
     add ff6f5c857af Implement `MessageQueueTrigger`

No new revisions were added by this update.

Summary of changes:
 .../airflow/providers/amazon/aws/triggers/sqs.py   |  4 +-
 providers/common/{msgq => messaging}/README.rst    |  0
 .../providers/common/messaging}/__init__.py        |  6 +-
 .../providers/common/messaging}/hooks/msg_queue.py | 18 ++---
 .../common/messaging}/operators/msg_queue.py       | 13 ++--
 .../common/messaging/triggers}/__init__.py         |  0
 .../common/messaging/triggers/msg_queue.py         | 79 ++++++++++++++++++++++
 .../providers/common/msgq/triggers/msg_queue.py    | 49 --------------
 8 files changed, 97 insertions(+), 72 deletions(-)
 rename providers/common/{msgq => messaging}/README.rst (100%)
 copy providers/{airbyte/src/airflow/providers/airbyte => common/messaging/src/airflow/providers/common/messaging}/__init__.py (90%)
 rename providers/common/{msgq/src/airflow/providers/common/msgq => messaging/src/airflow/providers/common/messaging}/hooks/msg_queue.py (92%)
 rename providers/common/{msgq/src/airflow/providers/common/msgq => messaging/src/airflow/providers/common/messaging}/operators/msg_queue.py (96%)
 copy {airflow/api_connexion => providers/common/messaging/src/airflow/providers/common/messaging/triggers}/__init__.py (100%)
 create mode 100644 providers/common/messaging/src/airflow/providers/common/messaging/triggers/msg_queue.py
 delete mode 100644 providers/common/msgq/src/airflow/providers/common/msgq/triggers/msg_queue.py