We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ef47e67 commit 0651675Copy full SHA for 0651675
sensors/sqs_service_sensor.py
@@ -54,7 +54,7 @@ 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",
+ self._sensor_service.dispatch(trigger="aws.sqs_new_message",
58
payload=payload)
59
msg.delete()
60
0 commit comments