Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/npm/tasks.py
Show All 39 Lines | def get_last_update_seq(lister): | ||||
return row[0] | return row[0] | ||||
@shared_task(name=__name__ + '.NpmListerTask') | @shared_task(name=__name__ + '.NpmListerTask') | ||||
def list_npm_full(**lister_args): | def list_npm_full(**lister_args): | ||||
'Full lister for the npm (javascript) registry' | 'Full lister for the npm (javascript) registry' | ||||
lister = NpmLister(**lister_args) | lister = NpmLister(**lister_args) | ||||
with save_registry_state(lister): | with save_registry_state(lister): | ||||
lister.run() | return lister.run() | ||||
@shared_task(name=__name__ + '.NpmIncrementalListerTask') | @shared_task(name=__name__ + '.NpmIncrementalListerTask') | ||||
def list_npm_incremental(**lister_args): | def list_npm_incremental(**lister_args): | ||||
'Incremental lister for the npm (javascript) registry' | 'Incremental lister for the npm (javascript) registry' | ||||
lister = NpmIncrementalLister(**lister_args) | lister = NpmIncrementalLister(**lister_args) | ||||
update_seq_start = get_last_update_seq(lister) | update_seq_start = get_last_update_seq(lister) | ||||
with save_registry_state(lister): | with save_registry_state(lister): | ||||
lister.run(min_bound=update_seq_start) | return lister.run(min_bound=update_seq_start) | ||||
@shared_task(name=__name__ + '.ping') | @shared_task(name=__name__ + '.ping') | ||||
def _ping(): | def _ping(): | ||||
return 'OK' | return 'OK' |