tobias/lrc-backend
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

changed thread pool code again

Browse Source
This commit is contained in:
Tobias Kurze
2019-11-14 15:05:06 +01:00
parent 6f1e01781a
commit 692649e08f
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
backend/tools/simple_state_checker.py
View File

@@ -6,6 +6,7 @@ from io import StringIO
import requests import requests
from requests.auth import HTTPBasicAuth from requests.auth import HTTPBasicAuth
from multiprocessing.pool import ThreadPool from multiprocessing.pool import ThreadPool
from multiprocessing.context import TimeoutError
from pprint import pprint from pprint import pprint
@@ -140,17 +141,13 @@ with ThreadPool(NUM_THREADS) as pool:
results = [pool.apply_async(check_capture_agent_state, (agent,)) for agent in agents] results = [pool.apply_async(check_capture_agent_state, (agent,)) for agent in agents]
try: try:
[res.get(timeout=12) for res in results] [res.get(timeout=12) for res in results]
except TimeoutError: except TimeoutError as e:
logger.error("Timeout while getting capture agent state!") logger.error("Timeout while getting capture agent state! {}".format(e))
pool.close() pool.close()
pool.join() pool.join()
logged_events = rec_err_state_log_stream.getvalue() logged_events = rec_err_state_log_stream.getvalue()
if len(logged_events) > 0: if len(logged_events) > 0:
send_error_mail(logged_events, "Errors have been detected while checking recorder states!") send_error_mail(logged_events, "Errors have been detected while checking recorder states!")
exit()
c = get_calender('CS 30.46 Chemie Neuer Hoersaal') logger.info("DONE checking capture agents / recorders!")
print(c.events)
print(list(c.timeline)) # chronological order
print(list(c.timeline.now()))