Compare commits
	
		
			4 Commits
		
	
	
		
			714bf4c863
			...
			lasso-1
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| c7cc0079a8 | |||
| c5522e8c72 | |||
| 7ecfd10d50 | |||
| d75baceae9 | 
@ -7,7 +7,7 @@
 | 
			
		||||
        "gasAdjustment": 1.0,
 | 
			
		||||
        "nodeRpc": "###RPC_URL###",
 | 
			
		||||
        "maxRetries": 10,
 | 
			
		||||
        "delay": 10,
 | 
			
		||||
        "delay": 30,
 | 
			
		||||
        "submitTx": false
 | 
			
		||||
    },
 | 
			
		||||
    "worker": [
 | 
			
		||||
 | 
			
		||||
@ -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)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
		Reference in New Issue
	
	Block a user