Commit 522cb584 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added 'getJobInfo()' and 'getJobResults' methods. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban.slack@gmail.com>
parent 9e069e6f

transfer_service/db_connector.py

+14 −0
Original line number Diff line number Diff line
@@ -117,6 +117,20 @@ class DbConnector(object): 
                out.close()

                return job



    def getJobInfo(self, jobId):

        """Returns the 'job_info' field, according to the UWS specification."""

        if self.conn:

            self.cursor.execute("SELECT job_info FROM job WHERE job_id = %s;", (jobId,))

            result = self.cursor.fetchall()

            return result[0]["job_info"]



    def getJobResults(self, jobId):

        """Returns the 'results' field, according to the UWS specification."""

        if self.conn:

            self.cursor.execute("SELECT results FROM job WHERE job_id = %s;", (jobId,))

            result = self.cursor.fetchall()

            return result[0]["results"]



    def listActiveJobs(self):

        """Returns some info about active jobs."""

        if self.conn: