diff --git a/ardumont/load_gitorious.py b/ardumont/load_gitorious.py index 07aedb2..8761799 100755 --- a/ardumont/load_gitorious.py +++ b/ardumont/load_gitorious.py @@ -1,59 +1,59 @@ #!/usr/bin/env python3 # Copyright (C) 2017 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 import click import os import sys from swh.scheduler.utils import get_task def load_repository_from_mapping( root_repositories_dir, origin_date, queue_name='swh_loader_git_express', dry_run=False): """Load a repository from a specific rootdir. """ for line in sys.stdin: origin_url, relative_repo_on_disk = line.strip().split(' ') # initiate task task = get_task('swh.loader.git.tasks.LoadDiskGitRepository') # but mutate the queue to use another queue than the default task.task_queue = queue_name directory_path = os.path.join( root_repositories_dir, relative_repo_on_disk) date = origin_date if dry_run: print('Would have send: {origin_url: %s, repo: %s, date: %s}' % ( origin_url, directory_path, date)) else: task.delay(origin_url=origin_url, directory=directory_path, - date=None) + date=date) @click.command() @click.option('--root-repositories', help='Upper root directory for storing repositories.') @click.option('--origin-date', default='Wed, 30 Mar 2016 09:40:04 +0200', help='Origin date to use.') @click.option('--dry-run/--no-dry-run', help='Do nothing but print.') def run(root_repositories, origin_date, dry_run): load_repository_from_mapping( root_repositories_dir=root_repositories, origin_date=origin_date, dry_run=dry_run) if __name__ == '__main__': run()