|
|
|
@ -44,10 +44,10 @@ Orchestrate(WorkerNode, autoscale=True, nodes=int, swarm_type="flat")
|
|
|
|
|
|
|
|
|
|
"""
|
|
|
|
|
#in a shared state, provide 3 communication times, during task assignment, task compeltion, and feedback or inability to complete a task.
|
|
|
|
|
import threading
|
|
|
|
|
from abc import ABC, abstractmethod
|
|
|
|
|
from typing import List, Dict, Any
|
|
|
|
|
from typing import Any, Dict, List
|
|
|
|
|
|
|
|
|
|
import threading
|
|
|
|
|
from swarms.agents.memory.ocean import OceanDB
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|