Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def restart(self):
- restart_all_messages = not self.filters
- while True:
- if not restart_all_messages and not self.filters:
- return
- messages = self._retrieve_messages()
- if not messages:
- return
- if not restart_all_messages:
- messages = self._filter_messages(messages)
- self.filters = [id for id in self.filters if id not in [msg.id for msg in messages]]
- send_sqs_message_batch(messages, self.queue_url)
- delete_sqs_message_batch(messages, self.dlt_queue_url)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement