import logging
+import os
import time
import threading
self.migrator = migrator
self.cleanup = cleanup
- def __init__(self, idx, cfg):
+ def __init__(self, idx, cache_dir, cfg):
self._idx = idx
source_idx = 1
self._sources = []
source_idx,
DirTrigger(src_dir_cfg['path'], src_dir_cfg['cool_time'],
src_dir_cfg['max_time']),
- Migrator(src_dir_cfg['path'], cfg['dst_dir']['path']),
+ Migrator(src_dir_cfg['path'], cfg['dst_dir']['path'],
+ os.path.join(cache_dir, "%d.db" % idx)),
src_dir_cfg['cleanup']
)
)
logging.info("Stopping bunch #%d...", self._idx)
self._stop = True
self._worker_thread.join()
+ for src in self._sources:
+ src.migrator.close()
logging.info("Stopped bunch #%d.", self._idx)
def is_running(self):