4 Commits

Author SHA1 Message Date
c7cc0079a8 fix bug 2024-08-28 02:24:48 +03:00
c5522e8c72 add timeout 2024-08-28 02:22:54 +03:00
7ecfd10d50 fix exit 2024-08-27 03:56:27 +03:00
d75baceae9 Update config.json 2024-08-26 17:22:44 +03:00
2 changed files with 13 additions and 12 deletions

View File

@ -7,7 +7,7 @@
"gasAdjustment": 1.0,
"nodeRpc": "###RPC_URL###",
"maxRetries": 10,
"delay": 10,
"delay": 30,
"submitTx": false
},
"worker": [

View File

@ -2,7 +2,6 @@ import subprocess
import json
import sys
import time
import os
def is_json(myjson):
try:
@ -11,7 +10,7 @@ def is_json(myjson):
return False
return True
def parse_logs():
def parse_logs(timeout):
start_time = time.time()
while True:
unsuccessful_attempts = 0
@ -50,26 +49,28 @@ def parse_logs():
return False, "Max Retry Reached"
except Exception as e:
print(f"Exception occurred: {e}", flush=True)
finally:
process.stdout.close()
print("Sleeping before next log request...", flush=True)
time.sleep(30)
if time.time() - start_time > 30 * 60:
print("Timeout reached: 30 minutes elapsed without success.", flush=True)
return False, "Timeout reached: 30 minutes elapsed without success."
if time.time() - start_time > timeout * 60:
print(f"Timeout reached: {timeout} minutes elapsed without success.", flush=True)
return False, f"Timeout reached: {timeout} minutes elapsed without success."
return False, "No Success"
if __name__ == "__main__":
print("Parsing logs...")
result = parse_logs()
if len(sys.argv) > 1:
timeout = eval(sys.argv[1])
else:
timeout = 30
result = parse_logs(timeout)
print(result[1])
if result[0] == False:
print("Exiting 1...")
os._exit(1)
sys.exit(1)
else:
print("Exiting 0...")
os._exit(0)
sys.exit(0)