#NEWLINE# def enqueue( self , item_id , process_datetime_str , redis_client = None ) : #NEWLINE# #INDENT# client = ( redis_client or get_redis_client ( ) ) #NEWLINE# queue_name = self . get_queue_name ( ) #NEWLINE# enqueuing_lock = self . get_enqueuing_lock ( client , ( '%s-enqueuing-%s-%s' % ( queue_name , item_id , process_datetime_str ) ) ) #NEWLINE# if enqueuing_lock . acquire ( blocking = False ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# self . enqueue_item ( item_id ) #NEWLINE# #UNINDENT# except : #NEWLINE# #INDENT# release_lock ( enqueuing_lock , True )