def _get_queue(): # Connect to Redis Queue return Queue('low', connection=conn) # These are constants because other components may listen for these # messages in logs: