28 lines
1.1 KiB
Python
28 lines
1.1 KiB
Python
# 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) |