#NEWLINE# def _dequeue_from( self , queue , grabfor = None ) : #NEWLINE# #INDENT# row = self . pop ( queue , grabfor = grabfor ) #NEWLINE# if JobCls : #NEWLINE# #INDENT# JobCls = util . get_toplevel_attr ( row [ 'body' ] [ 'cls' ] ) #NEWLINE# j = JobCls . __deserialize__ ( row [ 'body' ] [ 'message' ] ) #NEWLINE# work_order = job . MonqueWorkOrder ( j ) #NEWLINE# work_order . __configure__ ( dict ( job_id = row [ '_id' ] , queue = queue , retries = row [ 'retries' ] , failures = row [ 'failures' ] , delay = datetime . timedelta ( 0 ) ) ) #NEWLINE# return work_order