Fix bad merge in local_worker_manager.py

google · Oct 18, 2023 · 1f0bffe · 1f0bffe
1 parent a3edb98
commit 1f0bffe
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/compiler_opt/distributed/local/local_worker_manager.py b/compiler_opt/distributed/local/local_worker_manager.py
@@ -78,7 +78,6 @@ def _run_impl(pipe: connection.Connection, worker_class: SerializedClass, *args,
   # jobs, this effectively limits the number of clang instances spawned.
   pool = concurrent.futures.ThreadPoolExecutor(max_workers=1)
   obj = cloudpickle.loads(worker_class)(*args, **kwargs)
-  obj = cloudpickle.loads(worker_class)(*args, **kwargs)
 
   # Pipes are not thread safe
   pipe_lock = threading.Lock()