switch/tasks.py

import time
from bson.objectid import ObjectId
from celery_app import celery_app
@celery_app.task
def process_data(data:dict)-> dict:
    return {"result": []}