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']
)
)
bunch_idx = 1
bunches = []
for bunch_cfg in cfg['bunches']:
- bunches.append( Bunch(bunch_idx, bunch_cfg) )
+ bunches.append( Bunch(bunch_idx, cfg['cache_dir'], bunch_cfg) )
bunch_idx += 1
for bunch in bunches: