Searched refs:_processing_limit (Results 1 – 1 of 1) sorted by relevance
559 processing_limit = self._processing_limit(tstate.mapreduce_spec)933 if self._processing_limit(spec) != -1:1008 def _processing_limit(self, spec): member in MapperWorkerCallbackHandler