-
Notifications
You must be signed in to change notification settings - Fork 0
/
check_on_jobs.py
23 lines (18 loc) · 1.06 KB
/
check_on_jobs.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
from monitor import *
from coordinator import *
path_dictionary = setup_paths()
## update which jobs are live
logger(path_dictionary['state_path'],'************************************************')
live_job_count = check_queue_for_live_jobs()
logger(path_dictionary['state_path'],str(datetime.datetime.now()) + ' monitoring, number of live jobs ' + str(live_job_count))
## update which results are avaiable
jobs_complete = check_all_current_convergence() ##
logger(path_dictionary['state_path'],str(datetime.datetime.now()) + ' number of successful jobs ' + str(jobs_complete))
## wake the tree
#logger(path_dictionary['staite_path'],str(datetime.datetime.now()) + ' waking_tree ' + str(live_job_count))
#wake_up_routine()
## send off oustanding jobs
submit_outstanding_jobs()
live_job_count = check_queue_for_live_jobs() #final check on live jobs
logger(path_dictionary['state_path'],str(datetime.datetime.now()) + ' going back to sleep, number of live jobs ' + str(live_job_count))
logger(path_dictionary['state_path'],'************************************************')