Fix timeout on async locks

Author: enriquetomasmb

nebula/core/utils/locker.py

@@ -64,8 +64,13 @@ async def acquire_async(self, *args, **kwargs):
         if not self._async_lock:
             raise RuntimeError("Use 'acquire' for acquiring non-async locks")
         if self._verbose:
-            logging.debug(f"🔒  Acquiring async lock [{self._name}] from {filename}:{lineno}")
-        await self._lock.acquire()
+            if "timeout" in kwargs:
+                logging.debug(
+                    f"🔒  Acquiring async lock [{self._name}] from {filename}:{lineno} with timeout {kwargs['timeout']}"
+                )
+            else:
+                logging.debug(f"🔒  Acquiring async lock [{self._name}] from {filename}:{lineno}")
+        await self._lock.acquire(*args, **kwargs)
 
     async def release_async(self, *args, **kwargs):
         caller = inspect.stack()[1]