diff options
| author | Zuul <zuul@review.opendev.org> | 2022-01-10 22:56:19 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2022-01-10 22:56:19 +0000 |
| commit | 185e6c4a39f622bc46ba4b2d972bd8c7ed975888 (patch) | |
| tree | d9e0ada31f21df3f8497c0f5282ebb0666586f21 | |
| parent | 38b9011094dbcfdd00e6446393816201e8256d38 (diff) | |
| parent | ba2cbd72f9deee5fedf15864dac41471f4402c82 (diff) | |
| download | taskflow-185e6c4a39f622bc46ba4b2d972bd8c7ed975888.tar.gz | |
Merge "Handle invalid redis entries in RedisJobBoard"4.6.4
| -rw-r--r-- | taskflow/jobs/backends/impl_redis.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/taskflow/jobs/backends/impl_redis.py b/taskflow/jobs/backends/impl_redis.py index 66133fe..8c1e511 100644 --- a/taskflow/jobs/backends/impl_redis.py +++ b/taskflow/jobs/backends/impl_redis.py @@ -826,11 +826,14 @@ return cmsgpack.pack(result) job_name = job_data['name'] job_sequence_id = job_data['sequence'] job_details = job_data.get('details', {}) - except (ValueError, TypeError, KeyError): + except (ValueError, TypeError, KeyError, exc.JobFailure): with excutils.save_and_reraise_exception(): LOG.warning("Incorrectly formatted job data found at" " key: %s[%s]", self.listings_key, raw_job_key, exc_info=True) + LOG.info("Deleting invalid job data at key: %s[%s]", + self.listings_key, raw_job_key) + self._client.hdel(self.listings_key, raw_job_key) else: postings.append(RedisJob(self, job_name, job_sequence_id, raw_job_key, uuid=job_uuid, |