Searched refs:_add_task (Results 1 – 1 of 1) sorted by relevance
771 self._add_task(task, spec, queue_name)980 def _add_task(cls, member in MapperWorkerCallbackHandler1050 cls._add_task(task, tstate.mapreduce_spec, queue_name)1577 MapperWorkerCallbackHandler._add_task(task,