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 | |||||