(self, key, job)
| 109 | return self.handle.backend.get(key) is not None |
| 110 | |
| 111 | def get_result(self, key, job): |
| 112 | # Get result value |
| 113 | result = self.handle.backend.get(key) |
| 114 | if result is None: |
| 115 | return self.UNDEFINED |
| 116 | |
| 117 | result = json.loads(result) |
| 118 | |
| 119 | # Clear result if not caching |
| 120 | if self.cache_by is None: |
| 121 | self.clear_cache_entry(key) |
| 122 | else: |
| 123 | if self.expire: |
| 124 | # Set/update expiration time |
| 125 | self.handle.backend.expire(key, self.expire) |
| 126 | self.clear_cache_entry(self._make_progress_key(key)) |
| 127 | |
| 128 | self.terminate_job(job) |
| 129 | return result |
| 130 | |
| 131 | def get_updated_props(self, key): |
| 132 | updated_props = self.handle.backend.get(self._make_set_props_key(key)) |
no test coverage detected