fix: Properly cleanup intakedb
parent
53b08e6181
commit
191975578e
|
@ -52,6 +52,6 @@ class Sanitizer():
|
||||||
'date': date, 'datetime': data['datetime']})
|
'date': date, 'datetime': data['datetime']})
|
||||||
pipeline.sadd('to_insert', uuid)
|
pipeline.sadd('to_insert', uuid)
|
||||||
pipeline.execute()
|
pipeline.execute()
|
||||||
self.redis_intake.delete(*uuid)
|
self.redis_intake.delete(*uuids)
|
||||||
self.ris_cache.sadd('for_ris_lookup', *for_ris_lookup)
|
self.ris_cache.sadd('for_ris_lookup', *for_ris_lookup)
|
||||||
unset_running(self.__class__.__name__)
|
unset_running(self.__class__.__name__)
|
||||||
|
|
Loading…
Reference in New Issue