Skip to content

Add debug logging to SQS hook #64652

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
shivaam wants to merge 1 commit into from
+16 −3
Closed

Add debug logging to SQS hook #64652

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 16 additions & 3 deletions providers/amazon/src/airflow/providers/amazon/aws/hooks/sqs.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,10 @@ def create_queue(self, queue_name: str, attributes: dict | None = None) -> dict:
:param attributes: additional attributes for the queue (default: None)
:return: dict with the information about the queue.
"""
return self.get_conn().create_queue(QueueName=queue_name, Attributes=attributes or {})
self.log.debug("Creating SQS queue %s with attributes %s", queue_name, attributes)
result = self.get_conn().create_queue(QueueName=queue_name, Attributes=attributes or {})
self.log.debug("Created SQS queue %s, response: %s", queue_name, result.get("QueueUrl"))
return result

@staticmethod
def _build_msg_params(
Expand Down Expand Up @@ -104,7 +107,10 @@ def send_message(
message_group_id=message_group_id,
message_deduplication_id=message_deduplication_id,
)
return self.get_conn().send_message(**params)
self.log.debug("Sending message to SQS queue %s with delay %ds", queue_url, delay_seconds)
result = self.get_conn().send_message(**params)
self.log.debug("Message sent to %s, MessageId: %s", queue_url, result.get("MessageId"))
return result

async def asend_message(
self,
Expand Down Expand Up @@ -138,5 +144,12 @@ async def asend_message(
message_deduplication_id=message_deduplication_id,
)

self.log.debug(
"Sending message (async) to SQS queue %s with delay %ds",
queue_url,
delay_seconds,
)
async with await self.get_async_conn() as async_conn:
return await async_conn.send_message(**params)
result = await async_conn.send_message(**params)
self.log.debug("Message sent (async) to %s, MessageId: %s", queue_url, result.get("MessageId"))
return result
Loading