Former-commit-id: 35b5264e23
35b5264e23
@ -24,6 +24,11 @@ class AbstractSwarm(ABC):
"""Run the swarm"""
pass
@abstractmethod
def arun(self):
"""Run the swarm Asynchronously"""
def add_worker(self, worker: "AbstractWorker"):
"""Add a worker to the swarm"""