File tree Expand file tree Collapse file tree 2 files changed +5
-14
lines changed
Expand file tree Collapse file tree 2 files changed +5
-14
lines changed Original file line number Diff line number Diff line change 66from .discovery import Discovery
77from .exceptions import BaseError
88from .messages import StopIteration , Error
9- from .factory import Factory , DeleteAgent
9+ from .factory import Factory
1010from .types import (
1111 AgentSpec ,
1212 Channel ,
@@ -69,11 +69,6 @@ async def deregister(self, *names: str) -> None:
6969 def channel (self ) -> Channel :
7070 return self ._channel
7171
72- async def delete (self , addr : Address ) -> None :
73- factory_addr = Address (name = addr .name )
74- msg = DeleteAgent (session_id = addr .id ).encode ()
75- await self ._channel .publish (factory_addr , msg , probe = False )
76-
7772
7873class BaseChannel (Channel ):
7974 async def publish_multi (
Original file line number Diff line number Diff line change 1616)
1717from coagent .core .messages import Cancel
1818from coagent .core .exceptions import BaseError
19- from coagent .core .factory import DeleteAgent
2019from coagent .core .types import Runtime
2120from coagent .core .util import clear_queue
2221
@@ -122,23 +121,20 @@ async def event_stream() -> AsyncIterator[str]:
122121 # Disconnected from the client.
123122
124123 # Delete the corresponding agent.
125- factory_addr = Address (name = addr .name )
126- delete_msg = DeleteAgent (session_id = addr .id ).encode ()
127- await self ._runtime .channel .publish (
128- factory_addr , delete_msg , probe = False
129- )
124+ await agent .delete ()
130125
131126 raise
132127
133128 return EventSourceResponse (event_stream ())
134129
135130 async def publish (self , request : Request ):
136131 data : dict = await request .json ()
132+ addr = Address .decode (data ["addr" ])
133+ msg = RawMessage .decode (data ["msg" ])
134+
137135 try :
138- msg = RawMessage .decode (data ["msg" ])
139136 await self ._update_message_header_extensions (msg , request )
140137
141- addr = Address .decode (data ["addr" ])
142138 resp : RawMessage | None = await self ._runtime .channel .publish (
143139 addr = addr ,
144140 msg = msg ,
You can’t perform that action at this time.
0 commit comments