Searched refs:_independent_worker_fn (Results 1 – 2 of 2) sorted by relevance
354 def _independent_worker_fn(*args, **kwargs): # pylint: disable=unused-argument function379 _independent_worker_fn,409 def _independent_worker_fn(*args, **kwargs): # pylint: disable=unused-argument function440 _independent_worker_fn,
357 def _independent_worker_fn( member in DistributeCoordinatorIntegrationTest404 threads = self.run_multiple_tasks_in_threads(self._independent_worker_fn,444 threads = self.run_multiple_tasks_in_threads(self._independent_worker_fn,