# import logging
#
# from celery import Celery
#
# from app.service.generate_batch_image.service_batch_generate_product_image import batch_generate_product
# from app.service.generate_batch_image.service_batch_generate_relight_image import batch_generate_relight
# from app.service.generate_batch_image.service_batch_pose_transform import batch_generate_pose_transform
#
# logger = logging.getLogger()
# celery_app = Celery('tasks', broker=f'amqp://rabbit:123456@18.167.251.121:5672//', backend='rpc://', BROKER_CONNECTION_RETRY_ON_STARTUP=True)
# celery_app.conf.worker_log_format = '%(asctime)s %(filename)s [line:%(lineno)d] %(levelname)s %(message)s'
# celery_app.conf.worker_hijack_root_logger = False
# logging.getLogger('pika').setLevel(logging.WARNING)
#
#
# @celery_app.task
# def batch_pose_transform_tasks(batch_request_data):
#     batch_generate_pose_transform(batch_request_data)
#
#
# @celery_app.task
# def batch_generate_relight_tasks(batch_request_data):
#     batch_generate_relight(batch_request_data)
#
#
# @celery_app.task
# def batch_generate_product_tasks(batch_request_data):
#     batch_generate_product(batch_request_data)