Upload folder using huggingface_hub
Browse files- multiplayer_chat/run.py +1 -0
multiplayer_chat/run.py
CHANGED
@@ -5,6 +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, 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)
|
|
|
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 |
+
print('AAAAAAAA2', orchestrator_node.node_url)
|
9 |
chat_initiator = AgentService(name="chat_initiator", fn="chat", worker_node_url=worker_nodes[0].node_url, orchestrator_node=orchestrator_node, flow_run=flow_run)
|
10 |
chat_receiver = AgentService(name="chat_receiver", fn="chat", worker_node_url=worker_nodes[1].node_url, orchestrator_node=orchestrator_node, flow_run=flow_run)
|
11 |
print('BBBBBBBB', chat_initiator.flow_run)
|