Searched refs:_run_task_in_thread (Results 1 – 1 of 1) sorted by relevance
397 def _run_task_in_thread(self, task_fn, cluster_spec, task_type, task_id, member in IndependentWorkerTestBase425 t = self._run_task_in_thread(task_fn, cluster_spec, task_type, task_id,