Drop concurrency (#4)

b-scheduler · Jun 6, 2024 · 925b512 · 925b512
1 parent 1c2ab71
commit 925b512
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/brq/consumer.py b/brq/consumer.py
@@ -58,9 +58,6 @@ async def cleanup(self):
         Cleanup, implement in subclass
         """
 
-    def copy(self):
-        return copy.deepcopy(self)
-
 
 class Consumer(DeferOperator, RunnableMixin):
     """

diff --git a/brq/daemon.py b/brq/daemon.py
@@ -11,8 +11,8 @@ class Daemon:
     Tool for daemonizing a consumer.
     """
 
-    def __init__(self, runnable: RunnableMixin, concurrency: int = 1):
-        self.runnables = [runnable.copy() for _ in range(concurrency)]
+    def __init__(self, *runnables: list[RunnableMixin]):
+        self.runnables = runnables
 
     async def run_forever(self, stop_signals: list = [signal.SIGINT, signal.SIGTERM]):
         loop = asyncio.get_event_loop()