chore: add check for emscripten

Author: makkus

CHANGELOG.md

@@ -1,6 +1,6 @@
 # Changelog
 
-## Version 0.5.16-0.5.23
+## Version 0.5.16-0.5.24
 
 - bugfixes, dependency updates, template, CI improvements
 

src/kiara/interfaces/__init__.py

@@ -22,6 +22,7 @@
 )
 
 from kiara.exceptions import KiaraException
+from kiara.utils import is_emscripten
 from kiara.utils.cli import terminal_print
 
 if TYPE_CHECKING:
@@ -332,9 +333,10 @@ def base_api(self) -> "BaseAPI":
                 )
                 os.execvp(sys.executable, (sys.executable,) + tuple(sys.argv))  # noqa
 
-        import fasteners
+        if not is_emscripten():
+            import fasteners
 
-        fasteners.InterProcessReaderWriterLock(self.lock_file(context))
+            fasteners.InterProcessReaderWriterLock(self.lock_file(context))
 
         api.set_active_context(context, create=True)
 

src/kiara/registries/ids/__init__.py

@@ -6,14 +6,16 @@
 #
 #  Mozilla Public License, version 2.0 (see LICENSE or https://www.mozilla.org/en-US/MPL/2.0/)
 import uuid
-from typing import Any, Dict, Type, Union
+from typing import TYPE_CHECKING, Any, Dict, Type, Union
 from weakref import WeakValueDictionary
 
 import structlog
-from fasteners import InterProcessLock
 
 from kiara.defaults import KIARA_MAIN_CONTEXT_LOCKS_PATH
-from kiara.utils import is_debug, is_develop
+from kiara.utils import is_debug, is_develop, is_emscripten
+
+if TYPE_CHECKING:
+    from fasteners import InterProcessLock
 
 logger = structlog.getLogger()
 
@@ -30,26 +32,32 @@ def __init__(self) -> None:
         self._process_context_locks: Dict[uuid.UUID, InterProcessLock] = {}
 
     def lock_context(self, context_id: uuid.UUID) -> bool:
-        if context_id not in self._process_context_locks.keys():
-            lock = InterProcessLock(
-                os.path.join(
-                    KIARA_MAIN_CONTEXT_LOCKS_PATH, f"context_{context_id}.lock"
+        if not is_emscripten():
+            from fasteners import InterProcessLock
+
+            if context_id not in self._process_context_locks.keys():
+                lock = InterProcessLock(
+                    os.path.join(
+                        KIARA_MAIN_CONTEXT_LOCKS_PATH, f"context_{context_id}.lock"
+                    )
                 )
-            )
-            self._process_context_locks[context_id] = lock
-        else:
-            lock = self._process_context_locks[context_id]
+                self._process_context_locks[context_id] = lock
+            else:
+                lock = self._process_context_locks[context_id]
 
-        aquired: bool = lock.acquire(blocking=False)
-        return aquired
+            aquired: bool = lock.acquire(blocking=False)
+            return aquired
+        else:
+            return True
 
     def unlock_context(self, context_id: uuid.UUID):
-        if context_id not in self._process_context_locks.keys():
-            return
+        if not is_emscripten():
+            if context_id not in self._process_context_locks.keys():
+                return
 
-        lock = self._process_context_locks[context_id]
-        if lock.acquired:
-            lock.release()
+            lock = self._process_context_locks[context_id]
+            if lock.acquired:
+                lock.release()
 
     def generate(
         self,

src/kiara/utils/__init__.py

@@ -8,6 +8,7 @@
 import inspect
 import os
 import re
+import sys
 from typing import TYPE_CHECKING, Dict, Iterable, List, Type, TypeVar
 
 import structlog
@@ -43,6 +44,12 @@ def is_develop() -> bool:
     return False
 
 
+def is_emscripten() -> bool:
+    """Check if we're running in Emscripten / Pyodide environment."""
+
+    return sys.platform == "emscripten"
+
+
 def get_dev_config() -> "KiaraDevSettings":
     from kiara.utils.develop import KIARA_DEV_SETTINGS