YAO/YAO-agent
1
0
Fork 0
mirror of https://github.com/newnius/YAO-agent.git synced 2025-06-07 13:51:56 +00:00
Code Issues Releases Wiki Activity

all in one

Browse Source
This commit is contained in:
Newnius 2019-12-26 16:49:13 +08:00
parent c4d791fe03
commit 47605ea654
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
main.py
View File

@ -206,7 +206,6 @@ class MyHandler(BaseHTTPRequestHandler):
def report(): def report():
print(KafkaBrokers)
interval = 5 interval = 5
while True: while True:
try: try:
@ -215,7 +214,7 @@ def report():
print("execute failed, ", msg_gpu) print("execute failed, ", msg_gpu)
stats = get_gpu_status() stats = get_gpu_status()
report_msg(stats) report_msg(stats)
t = threading.Thread(target=launch_tasks, name='launch_tasks', args=(stats,)) t = Thread(target=launch_tasks, name='launch_tasks', args=(stats,))
t.start() t.start()
time.sleep(interval) time.sleep(interval)
except Exception as e: except Exception as e:
@ -291,7 +290,7 @@ def report_msg(stats):
print(result) print(result)
def listen(): def listener():
try: try:
# Create a web server and define the handler to manage the # Create a web server and define the handler to manage the
# incoming request # incoming request
@ -307,8 +306,8 @@ def listen():
def main(): def main():
t1 = Thread(target=report()) t1 = Thread(target=report)
t2 = Thread(target=listen()) t2 = Thread(target=listener)
t1.start() t1.start()
t2.start() t2.start()
print("started") print("started")