#NEWLINE# def generic_enqueue( worker_path , parameters , timeout = 60 , priority = 'medium' , async_process = True , connection = None ) : #NEWLINE# #INDENT# q = Enqueuer ( worker_path , async_process = async_process , timeout = timeout , priority = priority , connection = connection ) #NEWLINE# try : #NEWLINE# #INDENT# q . enqueue_job ( * parameters ) #NEWLINE# #UNINDENT# except ConnectionError as e : #NEWLINE# #INDENT# logger . error ( 'REDIS FAIL: Redis seems to be down' ) #NEWLINE# logger . error ( e ) #NEWLINE# #UNINDENT# except Exception as e : #NEWLINE# #INDENT# logger . error ( ( "REDIS FAIL: ERROR ENQUEING '%s' IN REDIS: %s" % ( worker_path , str ( e ) ) ) )