[airflow] branch main updated: Break AwaitMessageTrigger execution when finding a message with the desired format (#31803)

[potiuk]

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

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 1b599c9fbf Break AwaitMessageTrigger execution when finding a message 
with the desired format (#31803)
1b599c9fbf is described below

commit 1b599c9fbfb6151a41a588edaa786745f50eec38
Author: Hussein Awala <huss...@awala.fr>
AuthorDate: Fri Jun 30 11:26:46 2023 +0200

    Break AwaitMessageTrigger execution when finding a message with the desired 
format (#31803)
    
    Signed-off-by: Hussein Awala <huss...@awala.fr>
    Co-authored-by: eladkal <45845474+elad...@users.noreply.github.com>
---
 airflow/providers/apache/kafka/triggers/await_message.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/airflow/providers/apache/kafka/triggers/await_message.py 
b/airflow/providers/apache/kafka/triggers/await_message.py
index 5445579e12..f2c1bb81ca 100644
--- a/airflow/providers/apache/kafka/triggers/await_message.py
+++ b/airflow/providers/apache/kafka/triggers/await_message.py
@@ -113,6 +113,7 @@ class AwaitMessageTrigger(BaseTrigger):
                 if rv:
                     await async_commit(asynchronous=False)
                     yield TriggerEvent(rv)
+                    break
                 else:
                     await async_commit(asynchronous=False)
                     await asyncio.sleep(self.poll_interval)