coosld/client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update slave.py

Browse Source
This commit is contained in:
xnico31 2025-01-10 16:17:58 +01:00
parent 0cef99d740
commit cc1291f2ae
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tig-benchmarker/slave.py
View File

@ -118,8 +118,8 @@ def send_results(session, master_ip, master_port, tig_worker_path, download_wasm
with open(f"{output_folder}/result.json") as f:
result = json.load(f)
submit_url = f"http://{master_ip}:{master_port}/submit-batch-root/{batch_id}"
logger.info(f"posting root to {submit_url}")
submit_url = f"https://{master_ip}/submit-batch-root/{batch_id}"
logger.info(f"posting root to master")
resp = session.post(submit_url, json=result)
if resp.status_code == 200:
FINISHED_BATCH_IDS[batch_id] = now()
@ -151,8 +151,8 @@ def send_results(session, master_ip, master_port, tig_worker_path, download_wasm
for n in batch["sampled_nonces"]
]
submit_url = f"http://{master_ip}:{master_port}/submit-batch-proofs/{batch_id}"
logger.info(f"posting proofs to {submit_url}")
submit_url = f"https://{master_ip}/submit-batch-proofs/{batch_id}"
logger.info(f"posting proofs ")
resp = session.post(submit_url, json={"merkle_proofs": proofs_to_submit})
if resp.status_code == 200:
FINISHED_BATCH_IDS[batch_id] = now()
@ -193,8 +193,8 @@ def process_batch(session, tig_worker_path, download_wasms_folder, num_workers,
def poll_batches(session, master_ip, master_port, output_path):
get_batches_url = f"http://{master_ip}:{master_port}/get-batches"
logger.info(f"fetching batches from {get_batches_url}")
get_batches_url = f"https://{master_ip}/get-batches"
logger.info(f"fetching batches ")
resp = session.get(get_batches_url)
if resp.status_code == 200: