Add a 'ping' task for every lister.

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'

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'

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'

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'

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'

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'