[Trace] fix annotation when add opentelemetry (#2869)

* add opentelemetry

* add opentelemetry

* add opentelemetry on dequeue

* add opentelemetry on dequeue

* add opentelemetry on dequeue

* fix annotation

* fix annotation when add opentelemetry

* fix opentelemetry-instrumentation-fastapi

* fix pentelemetry-bootstrap

---------

Co-authored-by: Jiang-Jia-Jun <163579578+Jiang-Jia-Jun@users.noreply.github.com>
This commit is contained in:
sg263
2025-07-17 10:29:16 +08:00
committed by GitHub
parent 9c25dcca0b
commit 52aca233e8
3 changed files with 1 additions and 3 deletions

View File

@@ -57,7 +57,6 @@ class LLMEngine(object):
Attributes: Attributes:
cfg (Config): Configuration object containing all the parameters. cfg (Config): Configuration object containing all the parameters.
cached_generated_tokens (queue.Queue): Queue to store generated tokens. cached_generated_tokens (queue.Queue): Queue to store generated tokens.
cached_generated_tokens (queue.Queue): Queue to store generated tokens.
scheduler (LocalScheduler or GlobalScheduler): Scheduling tasks. scheduler (LocalScheduler or GlobalScheduler): Scheduling tasks.
input_processor (InputPreprocessor): Preprocessor for input data. input_processor (InputPreprocessor): Preprocessor for input data.
resource_manager (ResourceManager): Manager for resource allocation. resource_manager (ResourceManager): Manager for resource allocation.

View File

@@ -36,4 +36,4 @@ opentelemetry-instrumentation-redis
opentelemetry-instrumentation-mysql opentelemetry-instrumentation-mysql
opentelemetry-distro  opentelemetry-distro 
opentelemetry-exporter-otlp opentelemetry-exporter-otlp
opentelemetry-instrumentation-fastapi

View File

@@ -150,7 +150,6 @@ class PostInstallCommand(install):
install.run(self) install.run(self)
# 执行自定义命令 # 执行自定义命令
subprocess.check_call(["opentelemetry-bootstrap", "-a", "install"]) subprocess.check_call(["opentelemetry-bootstrap", "-a", "install"])
subprocess.check_call(["pip", "install", "opentelemetry-instrumentation-fastapi"])
def load_requirements(): def load_requirements():
"""Load dependencies from requirements.txt""" """Load dependencies from requirements.txt"""