naptha-sdk-py3.12➜ naptha-sdk git:(main) naptha run orchestrator:keynesian_beauty_contest -p "num_agents=100" --agent_nodes "localhost"
2025-02-26 09:41:41,031 - naptha_sdk.client.node - INFO - Node URL: http://localhost:7001
2025-02-26 09:41:41,031 - naptha_sdk.inference - INFO - Node URL: http://localhost:7001
2025-02-26 09:41:41,031 - naptha_sdk.client.hub - INFO - Hub URL: ws://localhost:3001/rpc
Parsed parameters: {'num_agents': '100'}
2025-02-26 09:41:41,051 - naptha_sdk.client.hub - INFO - Attempting authentication for user: enricorotundo1
2025-02-26 09:41:41,075 - naptha_sdk.client.hub - INFO - Successfully authenticated user: enricorotundo1
Found user... {'id': 'user:d217b4585f6b75d6849b9f39be32af6543d15f56a9e98301d61867214defc6caa5a6a393c2f7849de25121f09c778159c7c82f747dfcca4ba2770306c894fa9c', 'public_key': 'd217b4585f6b75d6849b9f39be32af6543d15f56a9e98301d61867214defc6caa5a6a393c2f7849de25121f09c778159c7c82f747dfcca4ba2770306c894fa9c', 'is_registered': True}
Running Orchestrator...
Run input: consumer_id='user:d217b4585f6b75d6849b9f39be32af6543d15f56a9e98301d61867214defc6caa5a6a393c2f7849de25121f09c778159c7c82f747dfcca4ba2770306c894fa9c' inputs={'num_agents': '100'} deployment=OrchestratorDeployment(node=NodeConfigUser(ip='localhost', user_communication_port=7001, user_communication_protocol='http'), name=None, module={'id': 'orchestrator:keynesian_beauty_contest', 'name': 'keynesian_beauty_contest', 'module_type': 'orchestrator'}, config=None, agent_deployments=[AgentDeployment(node=NodeConfigUser(ip='localhost', user_communication_port=None, user_communication_protocol=None), name=None, module=None, config=None, data_generation_config=None, tool_deployments=None, environment_deployments=None, kb_deployments=None, memory_deployments=None)], environment_deployments=[], kb_deployments=[], memory_deployments=[]) signature='807b7a7e09345ce0bf3a78292b95066ed956ab71da10ef69f295aae5e3ebd35e5049708922b6962de4e19c038d5551abb577cfa60ef6a85593f72a6ad5067d64'
Module type: orchestrator
Running orchestrator...
Run input: consumer_id='user:d217b4585f6b75d6849b9f39be32af6543d15f56a9e98301d61867214defc6caa5a6a393c2f7849de25121f09c778159c7c82f747dfcca4ba2770306c894fa9c' inputs={'num_agents': '100'} deployment=OrchestratorDeployment(node=NodeConfigUser(ip='localhost', user_communication_port=7001, user_communication_protocol='http'), name=None, module={'id': 'orchestrator:keynesian_beauty_contest', 'name': 'keynesian_beauty_contest', 'module_type': 'orchestrator'}, config=None, agent_deployments=[AgentDeployment(node=NodeConfigUser(ip='localhost', user_communication_port=None, user_communication_protocol=None), name=None, module=None, config=None, data_generation_config=None, tool_deployments=None, environment_deployments=None, kb_deployments=None, memory_deployments=None)], environment_deployments=[], kb_deployments=[], memory_deployments=[]) signature='807b7a7e09345ce0bf3a78292b95066ed956ab71da10ef69f295aae5e3ebd35e5049708922b6962de4e19c038d5551abb577cfa60ef6a85593f72a6ad5067d64'
Node URL: http://localhost:7001
Orchestrator run started: consumer_id='user:d217b4585f6b75d6849b9f39be32af6543d15f56a9e98301d61867214defc6caa5a6a393c2f7849de25121f09c778159c7c82f747dfcca4ba2770306c894fa9c' inputs={'num_agents': '100'} deployment=OrchestratorDeployment(node=NodeConfig(id='node:08269d0777434062405c0809924b5c433d34d276a7669f123ee226befec4dda064d05bf4eb94b8beb8fd44cb64bab756e5f35f9c68b37003cd7b2ba46c4294a9', owner='enricorotundo', public_key='08269d0777434062405c0809924b5c433d34d276a7669f123ee226befec4dda064d05bf4eb94b8beb8fd44cb64bab756e5f35f9c68b37003cd7b2ba46c4294a9', ip='localhost', user_communication_protocol='http', node_communication_protocol='grpc', user_communication_port=7001, num_node_communication_servers=1, provider_types=['models', 'storage', 'modules'], servers=[NodeServer(communication_protocol='grpc', port=7002, node_id='node:08269d0777434062405c0809924b5c433d34d276a7669f123ee226befec4dda064d05bf4eb94b8beb8fd44cb64bab756e5f35f9c68b37003cd7b2ba46c4294a9')], models=[''], docker_jobs=False, ports=[7002], routing_type='direct', routing_url='ws://node.naptha.ai:8765', num_gpus=0, arch='arm64', os='Darwin', ram=17179869184, vram=0), name='orchestrator_1', module={'id': 'orchestrator:keynesian_beauty_contest', 'name': 'keynesian_beauty_contest', 'description': 'A network of agents that guess random numbers', 'author': 'user:naptha', 'module_url': 'https://github.com/moarshy/keynesian_beauty_contest', 'module_type': 'orchestrator', 'module_version': 'v0.1', 'module_entrypoint': 'run.py', 'execution_type': 'package'}, config=OrchestratorConfig(config_name='agent_config_1', llm_config=None, max_rounds=10), agent_deployments=[AgentDeployment(node=NodeConfig(id='node:08269d0777434062405c0809924b5c433d34d276a7669f123ee226befec4dda064d05bf4eb94b8beb8fd44cb64bab756e5f35f9c68b37003cd7b2ba46c4294a9', owner='enricorotundo', public_key='08269d0777434062405c0809924b5c433d34d276a7669f123ee226befec4dda064d05bf4eb94b8beb8fd44cb64bab756e5f35f9c68b37003cd7b2ba46c4294a9', ip='localhost', user_communication_protocol='http', node_communication_protocol='grpc', user_communication_port=7001, num_node_communication_servers=1, provider_types=['models', 'storage', 'modules'], servers=[NodeServer(communication_protocol='grpc', port=7002, node_id='node:08269d0777434062405c0809924b5c433d34d276a7669f123ee226befec4dda064d05bf4eb94b8beb8fd44cb64bab756e5f35f9c68b37003cd7b2ba46c4294a9')], models=[''], docker_jobs=False, ports=[7002], routing_type='direct', routing_url='ws://node.naptha.ai:8765', num_gpus=0, arch='arm64', os='Darwin', ram=17179869184, vram=0), name='agent_deployment_1', module={'id': 'agent:random_number_agent', 'name': 'random_number_agent', 'description': 'A simple agent for taking part in Keynesian beauty contests', 'author': 'user:naptha', 'module_url': 'https://github.com/NapthaAI/random_number_agent', 'module_type': 'agent', 'module_version': 'v0.6', 'module_entrypoint': 'run.py', 'execution_type': 'package'}, config=AgentConfig(config_name='agent_config_1', llm_config=LLMConfig(config_name='model_1', client=<LLMClientType.OLLAMA: 'ollama'>, model='ollama/phi', max_tokens=1000, temperature=0.7, api_base='http://localhost:11434', options=None), persona_module=None, system_prompt=None), data_generation_config=DataGenerationConfig(save_outputs=None, save_outputs_location=None, save_outputs_path='/Users/enricorotundo/git/naptha/node/node/storage/fs/c2fec55c-5360-42c4-b3cc-7cbb2b4f6349/None', save_inputs=None, save_inputs_location=None, default_filename=None), tool_deployments=None, environment_deployments=None, kb_deployments=None, memory_deployments=None)], environment_deployments=[], kb_deployments=[], memory_deployments=[]) status='pending' error=False id='970aa25b-3428-4066-98e3-0ac260b69b01' results=[] error_message=None created_time=None start_processing_time=None completed_time=None duration=None agent_runs=[] input_schema_ipfs_hash=None signature='807b7a7e09345ce0bf3a78292b95066ed956ab71da10ef69f295aae5e3ebd35e5049708922b6962de4e19c038d5551abb577cfa60ef6a85593f72a6ad5067d64'
pending orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
running orchestrator keynesian_beauty_contest
error orchestrator keynesian_beauty_contest
Error in _run_module_async: Module execution failed: list index out of range
[2025-02-26 09:42:22,476: ERROR/ForkPoolWorker-64] Module import paths: ['/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest', '/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/.venv/lib/python3.12/site-packages']
[2025-02-26 09:42:22,477: ERROR/ForkPoolWorker-64] Current working directory: /Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest
[2025-02-26 09:42:22,480: ERROR/ForkPoolWorker-64] Module directory contents: [PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/pyproject.toml'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/tests'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/keynesian_beauty_contest'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/README.md'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/.gitignore'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/.venv'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/.gitattributes'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/poetry.lock'), PosixPath('/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/.git')]
[2025-02-26 09:42:22,483: ERROR/ForkPoolWorker-64] Error running orchestrator: Module execution failed: list index out of range
[2025-02-26 09:42:22,486: ERROR/ForkPoolWorker-64] Traceback: Traceback (most recent call last):
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 271, in load_and_run
result = await run_func(module_run=module_run_dict)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/keynesian_beauty_contest/run.py", line 61, in run
results = await beauty_contest.run_beauty_contest(module_run, *args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/keynesian_beauty_contest/run.py", line 51, in run_beauty_contest
results = [result.results[0] for result in results]
~~~~~~~~~~~~~~^^^
IndexError: list index out of range
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 342, in start_run
response = await loader.load_and_run(
^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 281, in load_and_run
raise RuntimeError(f"Module execution failed: {str(e)}") from e
RuntimeError: Module execution failed: list index out of range
[2025-02-26 09:42:22,486: ERROR/ForkPoolWorker-64] Error in _run_module_async: Module execution failed: list index out of range
[2025-02-26 09:42:22,487: ERROR/ForkPoolWorker-64] Traceback: Traceback (most recent call last):
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 271, in load_and_run
result = await run_func(module_run=module_run_dict)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/keynesian_beauty_contest/run.py", line 61, in run
results = await beauty_contest.run_beauty_contest(module_run, *args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/enricorotundo/git/naptha/node/node/storage/hub/modules/keynesian_beauty_contest/keynesian_beauty_contest/run.py", line 51, in run_beauty_contest
results = [result.results[0] for result in results]
~~~~~~~~~~~~~~^^^
IndexError: list index out of range
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 126, in _run_module_async
await module_run_engine.start_run(user_env_data)
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 342, in start_run
response = await loader.load_and_run(
^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/enricorotundo/git/naptha/node/node/worker/package_worker.py", line 281, in load_and_run
raise RuntimeError(f"Module execution failed: {str(e)}") from e
RuntimeError: Module execution failed: list index out of range
[2025-02-26 09:42:22,488: INFO/ForkPoolWorker-64] Updating LocalDBPostgres with OrchestratorRun
[2025-02-26 09:42:22,525: INFO/ForkPoolWorker-64] Updated orchestrator module run: True
[2025-02-26 09:42:22,536: INFO/ForkPoolWorker-64] Task node.worker.package_worker.run_orchestrator[f94d76f7-946d-402f-9adc-a50ef4bddef9] succeeded in 39.76988862498547s: None
2025-02-26 09:41:42 - node.storage.db.db - INFO - Created orchestrator run
2025-02-26 09:41:42 - node.server.http_server - INFO - Validating user user:d217b4585f6b75d6849b9f39be32af6543d15f56a9e98301d61867214defc6caa5a6a393c2f7849de25121f09c778159c7c82f747dfcca4ba2770306c894fa9c access on worker nodes
2025-02-26 09:41:42 - node.worker.main - INFO - Setting up event loop...
2025-02-26 09:41:42 - node.worker.main - INFO - ✓ Event loop setup complete
2025-02-26 09:41:42 - node.worker.main - INFO - File descriptor limits - Soft: 256, Hard: 9223372036854775807
2025-02-26 09:41:42 - node.worker.main - INFO - Open files count: 2
2025-02-26 09:41:42 - node.worker.main - INFO - Process memory usage: 95.47 MB
2025-02-26 09:41:42 - node.worker.main - INFO - CPU usage: 0.0%
2025-02-26 09:41:42 - node.worker.main - INFO - Event loop running: True
2025-02-26 09:41:42 - node.worker.main - INFO - Event loop closed: False
INFO: 127.0.0.1:63101 - "POST /orchestrator/run HTTP/1.1" 200 OK
2025-02-26 09:41:42 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:41:42 - node.server.http_server - INFO - Found orchestrator status: pending
INFO: 127.0.0.1:63110 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:41:45 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:41:45 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63169 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:41:48 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:41:48 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63247 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:41:51 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:41:51 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63284 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:41:54 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:41:54 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63339 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:41:57 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:41:57 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63373 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:01 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:01 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63405 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:04 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:04 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63433 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:07 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:07 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63469 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:10 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:10 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63497 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:13 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:13 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63527 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:16 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:16 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63575 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:19 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:19 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63659 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:22 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:22 - node.server.http_server - INFO - Found orchestrator status: running
INFO: 127.0.0.1:63707 - "POST /orchestrator/check HTTP/1.1" 200 OK
2025-02-26 09:42:25 - node.server.http_server - INFO - Checking orchestrator run
2025-02-26 09:42:25 - node.server.http_server - INFO - Found orchestrator status: error
2025-02-26 09:42:25 - node.server.http_server - ERROR - Orchestrator run failed. Returning error: Error in _run_module_async: Module execution failed: list index out of range
INFO: 127.0.0.1:63716 - "POST /orchestrator/check HTTP/1.1" 200 OK
CLI (
main):Celery:
http server: