(self, jobstatus)
| 178 | return ids |
| 179 | |
| 180 | def updateTimeStamp(self, jobstatus): |
| 181 | jobId = jobstatus.jobId |
| 182 | if jobId is not None and self.db is not None: |
| 183 | result = self.db.execute( |
| 184 | "select job_status, created, last_updated from async_job where\ |
| 185 | id='%s'" % str(jobId)) |
| 186 | if result is not None and len(result) > 0: |
| 187 | if result[0][0] == 1: |
| 188 | jobstatus.status = True |
| 189 | else: |
| 190 | jobstatus.status = False |
| 191 | jobstatus.startTime = result[0][1] |
| 192 | jobstatus.endTime = result[0][2] |
| 193 | delta = jobstatus.endTime - jobstatus.startTime |
| 194 | jobstatus.duration = delta.total_seconds() |
| 195 | |
| 196 | def waitForComplete(self, workers=10): |
| 197 | self.inqueue.join() |
no test coverage detected