from main import celery_app

@celery_app.task
def sample_task(param):
    print(param)