This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 14b9e9b27a4 Fix docstring for AwaitMessageSensor and
AwaitMessageTrigger in apache-kafka-provider (#63333)
14b9e9b27a4 is described below
commit 14b9e9b27a496b84eaff3347d0f09498c0c80eee
Author: Filipp <[email protected]>
AuthorDate: Wed Mar 11 17:04:07 2026 +0300
Fix docstring for AwaitMessageSensor and AwaitMessageTrigger in
apache-kafka-provider (#63333)
---
.../apache/kafka/src/airflow/providers/apache/kafka/sensors/kafka.py | 2 +-
.../kafka/src/airflow/providers/apache/kafka/triggers/await_message.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/providers/apache/kafka/src/airflow/providers/apache/kafka/sensors/kafka.py
b/providers/apache/kafka/src/airflow/providers/apache/kafka/sensors/kafka.py
index 05ad8259550..74bb12804f8 100644
--- a/providers/apache/kafka/src/airflow/providers/apache/kafka/sensors/kafka.py
+++ b/providers/apache/kafka/src/airflow/providers/apache/kafka/sensors/kafka.py
@@ -34,7 +34,7 @@ class AwaitMessageSensor(BaseSensorOperator):
The behavior of the consumer for this trigger is as follows:
- poll the Kafka topics for a message
- if no message returned, sleep
- - process the message with provided callable and commit the message offset
+ - process the message with provided callable
- if commit_offset is True (default), commit the message offset after
processing
- if callable returns any data, raise a TriggerEvent with the return data
- else continue to next message
diff --git
a/providers/apache/kafka/src/airflow/providers/apache/kafka/triggers/await_message.py
b/providers/apache/kafka/src/airflow/providers/apache/kafka/triggers/await_message.py
index 755969bbc58..28dde4abb84 100644
---
a/providers/apache/kafka/src/airflow/providers/apache/kafka/triggers/await_message.py
+++
b/providers/apache/kafka/src/airflow/providers/apache/kafka/triggers/await_message.py
@@ -41,7 +41,7 @@ class AwaitMessageTrigger(BaseEventTrigger):
The behavior of the consumer of this trigger is as follows:
- poll the Kafka topics for a message, if no message returned, sleep
- - process the message with provided callable and commit the message offset:
+ - process the message with provided callable:
- if callable is provided and returns any data, raise a TriggerEvent
with the return data
- else raise a TriggerEvent with the original message
