Former-commit-id: 0a69eeaa419dc6ec045e319954d24aaa6fcac59b
@ -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"""