WIP

ray-project · Jul 6, 2023 · 51e0f09 · 51e0f09
1 parent be7f321
commit 51e0f09
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 13 deletions.
diff --git a/fed/cleanup.py b/fed/cleanup.py
@@ -45,7 +45,6 @@ def _start(self):
         def __check_func():
             self._check_sending_objs()
 
-        # with LockGuard(self._lock_on_send_thread):
         self._check_send_thread = threading.Thread(target=__check_func)
         self._check_send_thread.start()
         logger.info('Start check sending thread.')
@@ -99,4 +98,3 @@ def _signal_exit():
                 break
 
         logger.info('Check sending thread was exited.')
-        logger.info('Clearing sending queue.')
diff --git a/fed/utils.py b/fed/utils.py
@@ -196,14 +196,3 @@ def validate_cluster_info(cluster: dict):
     """
     for _, info in cluster.items():
         validate_address(info['address'])
-
-
-class LockGuard:
-    def __init__(self, lock):
-        self._lock = lock
-
-    def __enter__(self):
-        self._lock.acquire()
-
-    def __exit__(self, exc_type, exc_val, exc_tb):
-        self._lock.release()