ferruzzi commented on code in PR #24554:
URL: https://github.com/apache/airflow/pull/24554#discussion_r901898253
##########
airflow/providers/amazon/aws/sensors/sqs.py:
##########
@@ -136,15 +135,27 @@ def poke(self, context: 'Context'):
messages = self.filter_messages(messages)
num_messages = len(messages)
self.log.info("There are %d messages left after filtering",
num_messages)
+ return messages
+
+ def poke(self, context: 'Context'):
+ """
+ Check for message on subscribed queue and write to xcom the message
with key ``messages``
Review Comment:
Nitpick suggestion:
```suggestion
Check subscribed queue for messages and write them to xcom with the
``messages`` key.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
