qingdan/tasks.py

from celery_app import celery_app
  
@celery_app.task
def process_data(data: dict) -> dict:
    import time
    time.sleep(5)
    return {"result": f"Processed {data['bianma']}"}