Searched refs:run_multiple_tasks_in_threads (Results 1 – 3 of 3) sorted by relevance
378 threads = self.run_multiple_tasks_in_threads(439 threads = self.run_multiple_tasks_in_threads(
404 threads = self.run_multiple_tasks_in_threads(self._independent_worker_fn,444 threads = self.run_multiple_tasks_in_threads(self._independent_worker_fn,
418 def run_multiple_tasks_in_threads(self, task_fn, cluster_spec, *args, member in IndependentWorkerTestBase