diff --git a/swh/loader/dir/tasks.py b/swh/loader/dir/tasks.py index c4b7c25..093c592 100644 --- a/swh/loader/dir/tasks.py +++ b/swh/loader/dir/tasks.py @@ -1,35 +1,34 @@ # Copyright (C) 2015-2016 The Software Heritage developers # See the AUTHORS file at the top-level directory of this distribution # License: GNU General Public License version 3, or any later version # See top-level LICENSE file for more information from swh.loader.dir.loader import DirLoader from swh.loader.core import tasks class LoadDirRepository(tasks.LoaderCoreTask): """Import a directory to Software Heritage """ + CONFIG_BASE_FILENAME = 'loader/dir.ini' task_queue = 'swh_loader_dir' def run(self, dir_path, origin, revision, release, occurrences): """Import a directory. Args: cf. swh.loader.dir.loader.run docstring """ - storage = DirLoader(origin_id=None).storage + origin['id'] = self.storage.origin_add_one(origin) - origin['id'] = storage.origin_add_one(origin) - - fetch_history_id = self.open_fetch_history(storage, origin['id']) + fetch_history_id = self.open_fetch_history(origin['id']) result = DirLoader(origin['id']).process(dir_path, origin, revision, release, occurrences) - self.close_fetch_history(storage, fetch_history_id, result) + self.close_fetch_history(fetch_history_id, result)