HomeSoftware Heritage

Add a new SWHTask class to be used as base class for swh celery tasks

Description

Add a new SWHTask class to be used as base class for swh celery tasks

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'

Details

Provenance
douarddaAuthored on Dec 21 2018, 4:52 PM
douarddaPushed on Jan 10 2019, 3:53 PM
Differential Revision
D886: Add a new SWHTask class to be used as base class for swh celery tasks
Parents
rDSCHb812434be7b5: Replace the TaskRouter class by a simple function
Branches
Unknown
Tags
Unknown
Build Status
Buildable 3364
Build 4339: test-and-build