Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/npm/tasks.py
| Show First 20 Lines • Show All 56 Lines • ▼ Show 20 Lines | |||||
| def npm_incremental_lister(self, **lister_args): | def npm_incremental_lister(self, **lister_args): | ||||
| self.log.debug('%s, lister_args=%s' % ( | self.log.debug('%s, lister_args=%s' % ( | ||||
| self.name, lister_args)) | self.name, lister_args)) | ||||
| 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) | lister.run(min_bound=update_seq_start) | ||||
| self.log.debug('%s OK' % (self.name)) | self.log.debug('%s OK' % (self.name)) | ||||
| @app.task(name='swh.lister.npm.tasks.ping', | |||||
| base=SWHTask, bind=True) | |||||
| def ping(self): | |||||
| self.log.debug(self.name) | |||||
| return 'OK' | |||||