diff --git a/swh/loader/cran/loader.py b/swh/loader/cran/loader.py new file mode 100644 --- /dev/null +++ b/swh/loader/cran/loader.py @@ -0,0 +1,14 @@ +from swh.loader.base.loader import BaseLoader +from swh.loader.base.dowload import If_Modified_Since + + +class CRANLoader(BaseLoader, If_Modified_Since): + loader_name = 'cran' + class_name = 'CRANLoader' + + def convert_to_standard_format(**kwargs): + return { + 'name': kwargs['name'], + 'origin_url': kwargs['origin_url'], + 'tarballs': kwargs['tarballs'] + } diff --git a/swh/loader/cran/task.py b/swh/loader/cran/task.py new file mode 100644 --- /dev/null +++ b/swh/loader/cran/task.py @@ -0,0 +1,7 @@ +from celery import current_app as app +from swh.loader.cran.loader import CRANLoader + + +@app.task(name=__name__ + '.LoadCRAN') +def load_cran(package_name, package_url=None, tarballs=None): + return CRANLoader().load(package_name, package_url, tarballs)