Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/phabricator/tasks.py
# Copyright (C) 2019 the Software Heritage developers | # Copyright (C) 2019 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 swh.scheduler.celery_backend.config import app | from swh.scheduler.celery_backend.config import app | ||||
from swh.lister.phabricator.lister import PhabricatorLister | from swh.lister.phabricator.lister import PhabricatorLister | ||||
def new_lister( | def new_lister(forge_url='https://forge.softwareheritage.org', api_token='', | ||||
forge_url='https://forge.softwareheritage.org', api_token='', **kw): | instance='swh', **kw): | ||||
return PhabricatorLister(forge_url=forge_url, api_token=api_token, **kw) | return PhabricatorLister(forge_url=forge_url, api_token=api_token, | ||||
instance=instance, **kw) | |||||
@app.task(name=__name__ + '.IncrementalPhabricatorLister') | @app.task(name=__name__ + '.IncrementalPhabricatorLister') | ||||
def incremental_phabricator_lister(**lister_args): | def incremental_phabricator_lister(**lister_args): | ||||
lister = new_lister(**lister_args) | lister = new_lister(**lister_args) | ||||
lister.run(min_bound=lister.db_last_index()) | lister.run(min_bound=lister.db_last_index()) | ||||
Show All 9 Lines |