(self, f, *args, **kwargs)
| 286 | self.jobs.put(job) |
| 287 | |
| 288 | def queue(self, f, *args, **kwargs): |
| 289 | args = (self, ) + args |
| 290 | job = DatabaseJob(f, *args, **kwargs) |
| 291 | self.jobs.put(job) |
| 292 | job.wait() |
| 293 | return job.result |
| 294 | |
| 295 | @classmethod |
| 296 | def registerSub(cls, klass): |
nothing calls this directly
no test coverage detected