Expose Celery Task Queue

[sooraj1002]

TASK

We need to expose the celery tasks which are pending for:

• Dataset generation @ranjanmangla1
• Training @sooraj1002
• Model Deployment @sooraj1002
• All scheduled tasks @ranjanmangla1

API Specifications:

REQUEST HEADERS

• user-id
• role
  [validation already handled in UserIdMixin]

RESPONSE

{
    "queued": [
        {
            "taskId": "CELERY_TASK_ID",
            "task_type": "infer from the task_name",
            "taskName": "task_name(from the Task Model)",
            "user": "user_id for user who created it",
            "taskArgs": "Expose using celery"
        },
        {
            "taskId": "CELERY_TASK_ID",
            "task_type": "infer from the task_name",
            "taskName": "task_name(from the Task Model)",
            "user": "user_id for user who created it",
            "taskArgs": "Expose using celery"
        }
    ],
    "scheduled": [
        {
            "taskId": "CELERY_TASK_ID",
            "task_type": "infer from the task_name",
            "taskName": "task_name(from the Task Model)",
            "user": "user_id for user who created it",
            "taskArgs": "Expose using celery",
            "scheduled_for": "Time in IST"
        },
        {
            "taskId": "CELERY_TASK_ID",
            "task_type": "infer from the task_name",
            "taskName": "task_name(from the Task Model)",
            "user": "user_id for user who created it",
            "taskArgs": "Expose using celery",
            "scheduled_for": "Time in IST"
        }
    ]
}

[ranjanmangla1]

hey @sooraj1002 , can I take this issue? I already have a lot of experience working with dramatiq (it is very close to celery)

[sooraj1002]

Sure. have assigned the ticket