import os
import redis
from rq import Worker, Queue, Connection

listen = ['high', 'default', 'low']

redis_url = os.getenv('REDIS_URL', 'redis://localhost:6379')
print('redis_url: ' + redis_url)

redis_conn = redis.from_url(redis_url)

if __name__ == '__main__':
  print("HI")
  with Connection(redis_conn):
    worker = Worker(map(Queue, listen))
    worker.work()

055a7c6155160c720d3c5a22ac9accd1a0f145c9
<mask token>

<mask token>
print('redis_url: ' + redis_url)
<mask token>
if __name__ == '__main__':
    print('HI')
    with Connection(redis_conn):
        worker = Worker(map(Queue, listen))
        worker.work()

<mask token>
listen = ['high', 'default', 'low']
redis_url = os.getenv('REDIS_URL', 'redis://localhost:6379')
print('redis_url: ' + redis_url)
redis_conn = redis.from_url(redis_url)
if __name__ == '__main__':
    print('HI')
    with Connection(redis_conn):
        worker = Worker(map(Queue, listen))
        worker.work()

import os
import redis
from rq import Worker, Queue, Connection
listen = ['high', 'default', 'low']
redis_url = os.getenv('REDIS_URL', 'redis://localhost:6379')
print('redis_url: ' + redis_url)
redis_conn = redis.from_url(redis_url)
if __name__ == '__main__':
    print('HI')
    with Connection(redis_conn):
        worker = Worker(map(Queue, listen))
        worker.work()

import os
import redis
from rq import Worker, Queue, Connection

listen = ['high', 'default', 'low']

redis_url = os.getenv('REDIS_URL', 'redis://localhost:6379')
print('redis_url: ' + redis_url)

redis_conn = redis.from_url(redis_url)

if __name__ == '__main__':
  print("HI")
  with Connection(redis_conn):
    worker = Worker(map(Queue, listen))
    worker.work()
