diff --git a/swh/lister/bitbucket/tasks.py b/swh/lister/bitbucket/tasks.py index 4d18213..841d6cc 100644 --- a/swh/lister/bitbucket/tasks.py +++ b/swh/lister/bitbucket/tasks.py @@ -50,3 +50,8 @@ def full_bitbucket_relister(self, split=None, **lister_args): self.log.debug('%s OK (spawned %s subtasks)' % (self.name, len(ranges))) +@app.task(name='swh.lister.bitbucket.tasks.ping', + base=SWHTask, bind=True) +def ping(self): + self.log.debug(self.name) + return 'OK' diff --git a/swh/lister/debian/tasks.py b/swh/lister/debian/tasks.py index a922195..875551f 100644 --- a/swh/lister/debian/tasks.py +++ b/swh/lister/debian/tasks.py @@ -15,3 +15,10 @@ def debian_lister(self, distribution, **lister_args): self.name, lister_args)) DebianLister(**lister_args).run(distribution) self.log.debug('%s OK' % (self.name)) + + +@app.task(name='swh.lister.debian.tasks.ping', + base=SWHTask, bind=True) +def ping(self): + self.log.debug(self.name) + return 'OK' diff --git a/swh/lister/github/tasks.py b/swh/lister/github/tasks.py index fdc7c39..eda4f51 100644 --- a/swh/lister/github/tasks.py +++ b/swh/lister/github/tasks.py @@ -51,3 +51,8 @@ def full_github_relister(self, split=None, **lister_args): self.log.debug('%s OK (spawned %s subtasks)' % (self.name, len(ranges))) +@app.task(name='swh.lister.github.tasks.ping', + base=SWHTask, bind=True) +def ping(self): + self.log.debug(self.name) + return 'OK' diff --git a/swh/lister/gitlab/tasks.py b/swh/lister/gitlab/tasks.py index eacb82f..eb8a4cb 100644 --- a/swh/lister/gitlab/tasks.py +++ b/swh/lister/gitlab/tasks.py @@ -57,3 +57,10 @@ def full_gitlab_relister(self, **lister_args): group(range_gitlab_lister.s(minv, maxv, **lister_args) for minv, maxv in ranges)() self.log.debug('%s OK (spawned %s subtasks)' % (self.name, len(ranges))) + + +@app.task(name='swh.lister.gitlab.tasks.ping', + base=SWHTask, bind=True) +def ping(self): + self.log.debug(self.name) + return 'OK' diff --git a/swh/lister/npm/tasks.py b/swh/lister/npm/tasks.py index d032061..a34290c 100644 --- a/swh/lister/npm/tasks.py +++ b/swh/lister/npm/tasks.py @@ -62,3 +62,10 @@ def npm_incremental_lister(self, **lister_args): with save_registry_state(lister): lister.run(min_bound=update_seq_start) 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' diff --git a/swh/lister/pypi/tasks.py b/swh/lister/pypi/tasks.py index 65e9348..5a1fc5f 100644 --- a/swh/lister/pypi/tasks.py +++ b/swh/lister/pypi/tasks.py @@ -17,3 +17,8 @@ def pypi_lister(self, **lister_args): self.log.debug('%s OK' % (self.name)) +@app.task(name='swh.lister.pypi.tasks.ping', + base=SWHTask, bind=True) +def ping(self): + self.log.debug(self.name) + return 'OK'