#NEWLINE# def push( self , job_name , args = ( ) , kwargs = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } , **opts ) : #NEWLINE# #INDENT# queue = QueueType ( self . get_queue_name ( job_name ) , connection = self . connection ) #NEWLINE# return queue . enqueue_call ( job_name , args = args , kwargs = kwargs , result_ttl = 0 , timeout = DEFAULT_JOB_TIMEOUT , ** opts )