From 5d75b6be62b81b2b7235b2b802a7902e25268942 Mon Sep 17 00:00:00 2001 From: Zhichang Yu Date: Fri, 14 Mar 2025 14:13:47 +0800 Subject: [PATCH] Fix executor name (#6080) ### What problem does this PR solve? Fix executor name ### Type of change - [x] Bug Fix (non-breaking change which fixes an issue) --- rag/svr/task_executor.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/rag/svr/task_executor.py b/rag/svr/task_executor.py index ea2ad7a74..d14ebc51a 100644 --- a/rag/svr/task_executor.py +++ b/rag/svr/task_executor.py @@ -24,9 +24,6 @@ from graphrag.general.index import run_graphrag from graphrag.utils import get_llm_cache, set_llm_cache, get_tags_from_cache, set_tags_to_cache from rag.prompts import keyword_extraction, question_proposal, content_tagging -CONSUMER_NO = "0" if len(sys.argv) < 2 else sys.argv[1] -CONSUMER_NAME = "task_executor_" + CONSUMER_NO - import logging import os from datetime import datetime @@ -87,7 +84,9 @@ FACTORY = { } UNACKED_ITERATOR = None -CONSUMER_NAME = "task_consumer_" + CONSUMER_NO + +CONSUMER_NO = "0" if len(sys.argv) < 2 else sys.argv[1] +CONSUMER_NAME = "task_executor_" + CONSUMER_NO BOOT_AT = datetime.now().astimezone().isoformat(timespec="milliseconds") PENDING_TASKS = 0 LAG_TASKS = 0