1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
# Copyright 1998-2016 Gentoo Foundation
# Distributed under the terms of the GNU General Public License v2
from __future__ import print_function
from tbc.sync import git_sync_main
#from tbc.buildquerydb import add_buildquery_main, del_buildquery_main
from tbc.updatedb import update_db_main
from tbc.old_cpv import remove_old_cpv_main
from tbc.sqlquerys import get_config_id, get_jobs, update_job_list
from tbc.log import write_log
def jobs_main(session, config_id):
JobsInfo = get_jobs(session, config_id)
if JobsInfo is None:
return
for JobInfo in JobsInfo:
job = JobInfo.JobType
run_config_id = JobInfo.RunConfigId
job_id = JobInfo.JobId
log_msg = "Job: %s Type: %s" % (job_id, job,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
if job == "addbuildquery":
update_job_list(session, "Runing", job_id)
log_msg = "Job %s is runing." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
#result = add_buildquery_main(run_config_id)
#if result is True:
# update_job_list(session, "Done", job_id)
# log_msg = "Job %s is done.." % (job_id,)
# write_log(session, log_msg, "info", config_id, 'jobs_main')
#else:
# update_job_list(session, "Fail", job_id)
# log_msg = "Job %s did fail." % (job_id,)
# write_log(session, log_msg, "info", config_id, 'jobs_main')
elif job == "delbuildquery":
update_job_list(session, "Runing", job_id)
log_msg = "Job %s is runing." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
#result = del_buildquery_main(config_id)
#if result is True:
# update_job_list(session, "Done", job_id)
# log_msg = "Job %s is done.." % (job_id,)
# write_log(session, log_msg, "info", config_id, 'jobs_main')
#else:
# update_job_list(session, "Fail", job_id)
# log_msg = "Job %s did fail." % (job_id,)
# write_log(session, log_msg, "info", config_id, 'jobs_main')
elif job == "esync":
update_job_list(session, "Runing", job_id)
log_msg = "Job %s is runing." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
if update_db_main(session, git_sync_main(session), config_id):
update_job_list(session, "Done", job_id)
log_msg = "Job %s is done.." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
else:
update_job_list(session, "Fail", job_id)
log_msg = "Job %s did fail." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
elif job == "updatedb":
update_job_list(session, "Runing", job_id)
log_msg = "Job %s is runing." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
if update_db_main(session, None, config_id):
update_job_list(session, "Done", job_id)
log_msg = "Job %s is done.." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
else:
update_job_list(session, "Fail", job_id)
log_msg = "Job %s did fail." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
elif job == "removeold_cpv":
update_job_list(session, "Runing", job_id)
log_msg = "Job %s is runing." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
remove_old_cpv_main(session, config_id)
update_job_list(session, "Done", job_id)
log_msg = "Job %s is done.." % (job_id,)
write_log(session, log_msg, "info", config_id, 'jobs_main')
return
|
GitWeb