Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/pypi/tasks.py
# Copyright (C) 2018 the Software Heritage developers | # Copyright (C) 2018 the Software Heritage developers | ||||
# License: GNU General Public License version 3, or any later version | # License: GNU General Public License version 3, or any later version | ||||
# See top-level LICENSE file for more information | # See top-level LICENSE file for more information | ||||
from ..core.tasks import ListerTaskBase | from swh.scheduler.task import SWHTask | ||||
from .lister import PyPILister | from swh.scheduler.celery_backend.config import app | ||||
from .lister import PyPILister | |||||
class PyPIListerTask(ListerTaskBase): | |||||
"""Full PyPI lister (list all available origins from the api). | |||||
""" | @app.task(name='swh.lister.pypi.tasks.PyPIListerTask', | ||||
task_queue = 'swh_lister_pypi_refresh' | base=SWHTask, bind=True) | ||||
def pypi_lister(self, **lister_args): | |||||
self.log.debug('%s(), lister_args=%s' % ( | |||||
self.name, lister_args)) | |||||
PyPILister(**lister_args).run() | |||||
self.log.debug('%s OK' % (self.name)) | |||||
def new_lister(self): | |||||
return PyPILister() | |||||
def run_task(self): | |||||
lister = self.new_lister() | |||||
lister.run() |