From 7d54d398c549ad4383fc61e0e854a06634868223 Mon Sep 17 00:00:00 2001 From: zhouchengrong Date: Wed, 11 Dec 2024 11:21:03 +0800 Subject: [PATCH] design design batch --- app/service/design_batch/design_batch_celery.py | 2 +- app/service/design_batch/service.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/app/service/design_batch/design_batch_celery.py b/app/service/design_batch/design_batch_celery.py index 9cca005..d1b4240 100644 --- a/app/service/design_batch/design_batch_celery.py +++ b/app/service/design_batch/design_batch_celery.py @@ -46,7 +46,7 @@ def process_layer(item, layers): layers.append(back_layer) -# @celery_app.task +@celery_app.task def batch_design(objects_data, tasks_id, json_name): object_response = [] threads = [] diff --git a/app/service/design_batch/service.py b/app/service/design_batch/service.py index e2a9b23..fcd278c 100644 --- a/app/service/design_batch/service.py +++ b/app/service/design_batch/service.py @@ -5,7 +5,7 @@ from app.service.design_batch.utils.MQ import publish_status async def start_design_batch_generate(data, file): - generate_clothes_task = batch_design(json.loads(file.decode())['objects'], data.total, data.file_name) + generate_clothes_task = batch_design.delay(json.loads(file.decode())['objects'], data.total, data.file_name) print(generate_clothes_task) publish_status(data.tasks_id, "0/100", "") return {"task_id": data.tasks_id}