Searched refs:_try_acquire_lease (Results 1 – 1 of 1) sorted by relevance
157 def _try_acquire_lease(self, shard_state, tstate): member in MapperWorkerCallbackHandler451 task_directive = self._try_acquire_lease(shard_state, tstate)