apunkt/MetaGPT
1
0
Fork 0
mirror of https://github.com/FoundationAgents/MetaGPT.git synced 2026-07-05 16:02:14 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

refine debate example

Browse source
This commit is contained in:
geekan 2023-12-22 18:53:44 +08:00
parent 41a174399e
commit 3feee73492
3 changed files with 14 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

17
metagpt/roles/role.py
View file

@ -144,7 +144,7 @@ class Role(BaseModel):
_states: list[str] = []
_actions: list[Action] = []
_rc: RoleContext = Field(default_factory=RoleContext)
_subscription: tuple[str] = set()
subscription: set[str] = set()
# builtin variables
recovered: bool = False # to tag if a recovered role
@ -183,7 +183,7 @@ class Role(BaseModel):
# 关于私有变量的初始化 https://github.com/pydantic/pydantic/issues/655
self._private_attributes["_llm"] = LLM() if not self.is_human else HumanProvider()
self._private_attributes["_role_id"] = str(self._setting)
self._private_attributes["_subscription"] = {any_to_str(self), self.name} if self.name else {any_to_str(self)}
self.subscription = {any_to_str(self), self.name} if self.name else {any_to_str(self)}
for key in self._private_attributes.keys():
if key in kwargs:
@ -322,9 +322,9 @@ class Role(BaseModel):
buffer to be further processed in _observe. By default, a Role subscribes Messages with a tag of its own name
or profile.
"""
self._subscription = tags
self.subscription = tags
if self._rc.env: # According to the routing feature plan in Chapter 2.2.3.2 of RFC 113
self._rc.env.set_subscription(self, self._subscription)
self._rc.env.set_subscription(self, self.subscription)
def _set_state(self, state: int):
"""Update the current state."""
@ -337,14 +337,9 @@ class Role(BaseModel):
messages by observing."""
self._rc.env = env
if env:
env.set_subscription(self, self._subscription)
env.set_subscription(self, self.subscription)
self.refresh_system_message() # add env message to system message
@property
def subscription(self) -> Set:
"""The labels for messages to be consumed by the Role object."""
return self._subscription
def _get_prefix(self):
"""Get the role prefix"""
if self.desc:
@ -418,7 +413,7 @@ class Role(BaseModel):
observed_pure = [msg.dict(exclude={"id": True}) for msg in observed]
existed_pure = [msg.dict(exclude={"id": True}) for msg in existed]
for idx, new in enumerate(observed_pure):
if new["cause_by"] in self._rc.watch and new not in existed_pure:
if (new["cause_by"] in self._rc.watch or self.name in new["send_to"]) and new not in existed_pure:
news.append(observed[idx])
return news

4
metagpt/team.py
View file

@ -120,10 +120,10 @@ class Team(BaseModel):
logger.info(self.json(ensure_ascii=False))
@serialize_decorator
async def run(self, n_round=3, idea=""):
async def run(self, n_round=3, idea="", send_to=""):
"""Run company until target round or no money"""
if idea:
self.run_project(idea=idea)
self.run_project(idea=idea, send_to=send_to)
while n_round > 0:
# self._save()