From 999e8d39ba068548b53562ba3911bbe376aa8e30 Mon Sep 17 00:00:00 2001
From: allegroai <>
Date: Sat, 26 Feb 2022 13:42:27 +0200
Subject: [PATCH] Fix don't crash on semaphore acquire error

---
 clearml/utilities/process/mp.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/clearml/utilities/process/mp.py b/clearml/utilities/process/mp.py
index 000a0c34..1bbb4b4f 100644
--- a/clearml/utilities/process/mp.py
+++ b/clearml/utilities/process/mp.py
@@ -84,7 +84,11 @@ class ForkSemaphore(_ForkSafeThreadSyncObject):
         super(ForkSemaphore, self).__init__(functor=partial(Semaphore, value))
 
     def acquire(self, *args, **kwargs):
-        self._create()
+        try:
+            self._create()
+        except BaseException:  # noqa
+            return None
+
         return self._sync.acquire(*args, **kwargs)
 
     def release(self, *args, **kwargs):