feat: updated source file loader

Author: cofin

examples/basic.py

@@ -26,6 +26,7 @@ async def samples_queue_info(self, task_queues: TaskQueues) -> QueueInfo:
     config=SAQConfig(
         redis_url="redis://localhost:6397/0",
         web_enabled=True,
+        use_server_lifespan=True,
         queue_configs=[
             QueueConfig(
                 name="samples",

litestar_saq/_util.py

@@ -1,10 +1,9 @@
 from __future__ import annotations
 
-import importlib
+import importlib.util
 import sys
 from functools import lru_cache
 from importlib import import_module
-from importlib.machinery import SourceFileLoader
 from pathlib import Path
 from typing import TYPE_CHECKING, Any
 
@@ -25,10 +24,10 @@ def module_to_os_path(dotted_path: str) -> Path:
     Ensures that pkgutil returns a valid source file loader.
     """
     src = importlib.util.find_spec(dotted_path)
-    if not isinstance(src, SourceFileLoader):
+    if src is None:
         msg = f"Couldn't find the path for {dotted_path}"
         raise TypeError(msg)
-    return Path(str(src.path).removesuffix("/__init__.py"))  # type: ignore[unreachable]
+    return Path(str(src.origin).removesuffix("/__init__.py"))  # type: ignore[unreachable]
 
 
 def import_string(dotted_path: str) -> Any:

litestar_saq/config.py

@@ -40,7 +40,7 @@ def serializer(value: Any) -> str:
 
 
 def _get_static_files() -> Path:
-    return Path(module_to_os_path("saq.web") / "static")
+    return Path(module_to_os_path("saq") / "web" / "static")
 
 
 @dataclass