from celery import shared_task
from celery.utils.log import get_task_logger
from api.celery import celery_app
logger = get_task_logger(__name__)
@celery_app.task
def upload_file(file_id):
logger.info('123')
logger.info(file_id)