pepperplus/pepperplus-cb
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Remove SPADE dependency #29

Merged
k.marinus merged 28 commits from refactor/remove-spade into dev 2025-11-25 10:26:07 +00:00
Conversation 57 Commits 28 Files Changed 51 +1 -6
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 67d0284dfb - Show all commits

7
src/control_backend/core/agent_system.py
View File

@@ -1,8 +1,7 @@
import asyncio import asyncio
import logging import logging
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
from dataclasses import dataclass, field from dataclasses import dataclass
from typing import Any
# Central directory to resolve agent names to instances # Central directory to resolve agent names to instances
_agent_directory: dict[str, "BaseAgent"] = {} _agent_directory: dict[str, "BaseAgent"] = {}
@@ -14,7 +13,6 @@ class InternalMessage:
sender: str sender: str
body: str body: str
thread: str | None = None thread: str | None = None
metadata: dict[str, Any] = field(default_factory=dict)
class AgentDirectory: class AgentDirectory:
@@ -32,7 +30,6 @@ class BaseAgent(ABC):
def __init__(self, name: str): def __init__(self, name: str):
self.name = name self.name = name
self.jid = name # present for backwards compatibility
self.inbox: asyncio.Queue[InternalMessage] = asyncio.Queue() self.inbox: asyncio.Queue[InternalMessage] = asyncio.Queue()
self._tasks: set[asyncio.Task] = set() self._tasks: set[asyncio.Task] = set()
self._running = False self._running = False
@@ -83,5 +80,3 @@ class BaseAgent(ABC):
task = asyncio.create_task(coro) task = asyncio.create_task(coro)
self._tasks.add(task) self._tasks.add(task)
task.add_done_callback(self._tasks.discard) task.add_done_callback(self._tasks.discard)
# await asyncio.sleep(1)