richardblythman commited on
Commit
c853af1
·
verified ·
1 Parent(s): 590c4b1

Upload folder using huggingface_hub

Browse files
Files changed (1) hide show
  1. multiplayer_chat/run.py +1 -1
multiplayer_chat/run.py CHANGED
@@ -5,7 +5,7 @@ logger = get_logger(__name__)
5
  async def run(inputs, worker_nodes = None, orchestrator_node = None, flow_run = None, cfg: dict = None):
6
  from naptha_sdk.agent_service import AgentService
7
  print('AAAAAAAA', orchestrator_node)
8
- chat_initiator = AgentService(name="chat_initiator", fn="chat", worker_node_url=worker_nodes[0].node_url, orchestrator_node=orchestrator_node.node, flow_run=flow_run)
9
  chat_receiver = AgentService(name="chat_receiver", fn="chat", worker_node_url=worker_nodes[1].node_url, orchestrator_node=orchestrator_node, flow_run=flow_run)
10
  print('BBBBBBBB', chat_initiator.flow_run)
11
 
 
5
  async def run(inputs, worker_nodes = None, orchestrator_node = None, flow_run = None, cfg: dict = None):
6
  from naptha_sdk.agent_service import AgentService
7
  print('AAAAAAAA', orchestrator_node)
8
+ chat_initiator = AgentService(name="chat_initiator", fn="chat", worker_node_url=worker_nodes[0].node_url, orchestrator_node=orchestrator_node, flow_run=flow_run)
9
  chat_receiver = AgentService(name="chat_receiver", fn="chat", worker_node_url=worker_nodes[1].node_url, orchestrator_node=orchestrator_node, flow_run=flow_run)
10
  print('BBBBBBBB', chat_initiator.flow_run)
11