Skip to content
Merged
Changes from 1 commit
Commits
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
4 changes: 2 additions & 2 deletions synapseutils/monitor.py
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ async def with_retry_and_messaging(*args, **kwargs):
while attempt <= retries:
try:
output = await func(*args, **kwargs)
syn.sendMessage(
await syn.sendMessage_async(
[destination],
messageSubject,
messageBody="Call to %s completed successfully!"
Expand All @@ -146,7 +146,7 @@ async def with_retry_and_messaging(*args, **kwargs):
syn.logger.exception(
f"Encountered a temporary Failure during execution. Will retry {retries - attempt} more times."
)
syn.sendMessage(
await syn.sendMessage_async(
[destination],
messageSubject,
messageBody=(
Expand Down
Loading