Skip to content

Instantly share code, notes, and snippets.

class SqsPriorityQueue():
def __init__(self, queue_urls, wait_time_seconds=10, max_messages=1):
self._queue_urls = queue_urls
self._wait_time_seconds = wait_time_seconds
self._max_messages = max_messages
self._sqs: SQSClient = boto3.client('sqs')
self.channels = []
trio.run(self._start)

Keybase proof

I hereby claim:

  • I am vin on github.
  • I am vin (https://keybase.io/vin) on keybase.
  • I have a public key whose fingerprint is 4125 3F10 521C 42A2 F42A 5419 EF3D D2DF 77D4 6FD1

To claim this, I am signing this object: