diff --git a/swarms/orchestrate.py b/swarms/orchestrate.py index f869fc3c..63ac5c10 100644 --- a/swarms/orchestrate.py +++ b/swarms/orchestrate.py @@ -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 diff --git a/tests/agents/workers/worker_ultra.py b/tests/agents/workers/worker_ultra.py index 94aca5e3..17b699e3 100644 --- a/tests/agents/workers/worker_ultra.py +++ b/tests/agents/workers/worker_ultra.py @@ -1,6 +1,6 @@ import pytest from unittest.mock import Mock, patch -from swarms.workers.worker_agent_ultra import WorkerUltraNode, WorkerUltraNodeInitializer # replace 'yourmodule' with the actual module name +from swarms.workers.worker_agent_ultra import WorkerUltraNode, WorkerUltraNodeInitializer @pytest.fixture def llm_mock():