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 = []
DirTrigger(src_dir_cfg['path'], src_dir_cfg['cool_time'],
src_dir_cfg['max_time']),
Migrator(src_dir_cfg['path'], cfg['dst_dir']['path'],
- os.path.join(cfg['cache_dir'], "%d.db" % idx)),
+ os.path.join(cache_dir, "%d.db" % idx)),
src_dir_cfg['cleanup']
)
)