Add a new SWHTask class to be used as base class for swh celery tasks
Closed
requested to merge generated-differential-D886-source into generated-differential-D886-target
It is meant to be used to declare swh tasks via the task decorator instead of subclassing the (now deprecated) Task class.
It is typically used like:
from swh.scheduler.celery_backend.config import app from swh.scheduler.tasks import SWHTask
@app.task(base=SWHTask) def ping(): return 'pong'
Also replace the TaskRouter class by a simple function class-based router is a remainder of celery 3.
Migrated from D886 (view on Phabricator)
Merge request reports
Activity
Please register or sign in to reply