diff --git a/warcprox/controller.py b/warcprox/controller.py index b3f3eaf..42f71de 100644 --- a/warcprox/controller.py +++ b/warcprox/controller.py @@ -211,8 +211,6 @@ class WarcproxController(object): if self.proxy.stats_db: self.proxy.stats_db.stop() - if any((t.dedup_db for t in self.warc_writer_threads)): - self.warc_writer_threads[0].dedup_db.close() self.proxy_thread.join() if self.playback_proxy is not None: diff --git a/warcprox/dedup.py b/warcprox/dedup.py index 78c5434..7a7a025 100644 --- a/warcprox/dedup.py +++ b/warcprox/dedup.py @@ -58,9 +58,6 @@ class DedupDb(object): def stop(self): pass - def close(self): - pass - def sync(self): pass @@ -154,9 +151,6 @@ class RethinkDedupDb: def stop(self): pass - def close(self): - pass - def sync(self): pass