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