We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7c3dcde commit ef47e67Copy full SHA for ef47e67
sensors/sqs_service_sensor.py
@@ -54,7 +54,8 @@ def run(self):
54
for msg in msgs:
55
if msg:
56
payload = {"queue": queue, "body": json.loads(msg.body)}
57
- self._sensor_service.dispatch(trigger="aws.sqs_new_message", payload=payload)
+ self._sensor_service.dispatch(trigger="aws.sqs_new_message",
58
+ payload=payload)
59
msg.delete()
60
61
def cleanup(self):
0 commit comments