Skip to content
Snippets Groups Projects

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'

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

Loading
Loading

Activity

Filter activity
  • Approvals
  • Assignees & reviewers
  • Comments (from bots)
  • Comments (from users)
  • Commits & branches
  • Edits
  • Labels
  • Lock status
  • Mentions
  • Merge request status
  • Tracking
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
Please register or sign in to reply
Loading