fix: local ask queue

PropsAI · Nov 15, 2024 · 2653658 · 2653658
1 parent 66f6bb5
commit 2653658
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/agentserve/queues/local_task_queue.py b/agentserve/queues/local_task_queue.py
@@ -1,14 +1,14 @@
 # agentserve/local_task_queue.py
 
 import asyncio
-from typing import Any, Dict
+from typing import Any, Dict, Optional
 from .task_queue import TaskQueue
 import threading
 from ..logging_config import setup_logger
 import concurrent.futures
 
 class LocalTaskQueue(TaskQueue):
-    def __init__(self):
+    def __init__(self, config: Optional[Dict[str, Any]] = None):
         self.logger = setup_logger("agentserve.queue.local")
         self.results = {}
         self.statuses = {}