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(cfg['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):