fix: dedup job infos closes #101

tobymao · Nov 18, 2023 · 6ccb7da · 6ccb7da
1 parent ac412a7
commit 6ccb7da
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/saq/queue.py b/saq/queue.py
@@ -202,7 +202,14 @@ async def info(
                     )
                 )
             )
-            job_info = [job.to_dict() for job in deserialized_jobs if job is not None]
+            job_info = list(
+                {
+                    job["key"]: job
+                    for job in (
+                        job.to_dict() for job in deserialized_jobs if job is not None
+                    )
+                }.values()
+            )
         else:
             job_info = []
 

diff --git a/saq/web/aiohttp.py b/saq/web/aiohttp.py
@@ -106,7 +106,7 @@ def create_app(queues: list[Queue]) -> Application:
     password = os.environ.get("AUTH_PASSWORD")
 
     if password:
-        from aiohttp_basicauth import BasicAuthMiddleware  # type: ignore[import-untyped]
+        from aiohttp_basicauth import BasicAuthMiddleware  # type: ignore
 
         user = os.environ.get("AUTH_USER", "admin")
         middlewares.append(BasicAuthMiddleware(username=user, password=password))