#NEWLINE# def enqueue( self , work_order , **kwargs ) : #NEWLINE# #INDENT# work_order . __configure__ ( work_order ) #NEWLINE# work_order . __configure__ ( self . _workorder_defaults ) #NEWLINE# self . push ( queue = work_order . queue , item = dict ( cls = util . get_toplevel_attrname ( work_order . job . __class__ ) , message = work_order . job . __serialize__ ( ) ) , delay = work_order . delay , retries = work_order . retries ) #NEWLINE# c = self . get_collection ( 'queue_stats' )