[gentoo-commits] dev/zorry:master commit in: gobs/bin/, gobs/pym/

[Magnus Granberg]

commit:     9d85fe87e992047e0972eceb82c0a81e819ed6f7
Author:     Magnus Granberg <zorry <AT> gentoo <DOT> org>
AuthorDate: Sun Apr 29 13:09:55 2012 +0000
Commit:     Magnus Granberg <zorry <AT> gentoo <DOT> org>
CommitDate: Sun Apr 29 13:09:55 2012 +0000
URL:        http://git.overlays.gentoo.org/gitweb/?p=dev/zorry.git;a=commit;h=9d85fe87

start of the job host deamon

---
 gobs/bin/gobs_host_jobs |   45 +++++++++++++++++++++++++++++++++++++++++++++
 gobs/pym/pgsql.py       |   18 ++++++++++++++++++
 2 files changed, 63 insertions(+), 0 deletions(-)

diff --git a/gobs/bin/gobs_host_jobs b/gobs/bin/gobs_host_jobs
new file mode 100755
index 0000000..856041c
--- /dev/null
+++ b/gobs/bin/gobs_host_jobs
@@ -0,0 +1,45 @@
+#!/usr/bin/python
+# Copyright 2006-2011 Gentoo Foundation
+# Distributed under the terms of the GNU General Public License v2
+
+from __future__ import print_function
+
+from gobs.init_setup_profile import setup_profile_main
+from gobs.readconf import get_conf_settings
+reader = get_conf_settings()
+gobs_settings_dict=reader.read_gobs_settings_all()
+
+# make a CM
+from gobs.ConnectionManager import connectionManager
+CM=connectionManager(gobs_settings_dict)
+#selectively import the pgsql/mysql querys
+if CM.getName()=='pgsql':
+	from gobs.pgsql import *
+# import logging
+
+def main():
+	# Main
+	config_profile = gobs_settings_dict['gobs_config']
+	# Logging
+	#logging.basicConfig(filename=gobs_settings_dict['gobs_logfile'], \
+	#	format='%(levelname)s: %(asctime)s %(message)s', level=logging.INFO)
+	conn = CM.getConnection()
+	CM.putConnection(conn)
+	repeat = True
+	while repeat:
+		conn = CM.getConnection()
+		job jobid = check_job_list(conn, config_profile)
+		print("job jobid:" + job + " " + jobid)
+		if job is None:
+			time.sleep(60)
+			CM.putConnection(conn)
+			continue
+		else:
+			update_job_list("Runing", jobid)
+			repeat = False
+		CM.putConnection(conn)
+		time.sleep(60)
+	connectionManager.closeAllConnections()
+	
+if __name__ == "__main__":
+	main()
\ No newline at end of file

diff --git a/gobs/pym/pgsql.py b/gobs/pym/pgsql.py
index db70f6c..21c204d 100644
--- a/gobs/pym/pgsql.py
+++ b/gobs/pym/pgsql.py
@@ -636,3 +636,21 @@ def add_fail_querue_dict(connection, fail_querue_dict):
 
 def make_conf_error(connection,config_profile):
   pass
+
+def check_job_list(connection, config_profile):
+	cursor = connection.cursor()
+	sqlQ1 = 'SELECT idnr FROM config WHERE id = %s'
+	sqlQ2 = "SELECT job, jobnr FROM jobs_list WHERE status = 'Waiting' AND config_id = %s" 
+	cursor.execute(sqlQ1, (config_profile,))
+	config_nr = cursor.fetchone()
+	cursor.execute(sqlQ2, (config_nr,))
+	job jobid = cursor.fetchone()
+	if job is None:
+		return None None
+	return job jobid
+	
+def update_job_list(status, jobid)
+	cursor = connection.cursor()
+	sqlQ = 'UPDATE  jobs_list SET ststus = %s WHERE jobid = %s'
+	cursor.execute(sqlQ, (status, jobid,))
+	connection.commit()