From aa3a575cbe9b15b205d3bf0e4b5f61a60da7f201 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Fri, 7 Feb 2025 13:26:48 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=E5=88=9D=E5=A7=8B?= =?UTF-8?q?=E5=8C=96=E6=AD=A5=E9=AA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/core/listeners/NodeIKernelSessionListener.ts | 2 +- src/shell/base.ts | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/core/listeners/NodeIKernelSessionListener.ts b/src/core/listeners/NodeIKernelSessionListener.ts index 49d853ba..bf82cbaf 100644 --- a/src/core/listeners/NodeIKernelSessionListener.ts +++ b/src/core/listeners/NodeIKernelSessionListener.ts @@ -11,7 +11,7 @@ export class NodeIKernelSessionListener { } - onOpentelemetryInit(args: unknown): any { + onOpentelemetryInit(info: { is_init: boolean, is_report: boolean }): any { } diff --git a/src/shell/base.ts b/src/shell/base.ts index 3430b4f0..4969fab9 100644 --- a/src/shell/base.ts +++ b/src/shell/base.ts @@ -236,11 +236,11 @@ async function initializeSession( ) { return new Promise((resolve, reject) => { const sessionListener = new NodeIKernelSessionListener(); - sessionListener.onSessionInitComplete = (r: unknown) => { - if (r === 0) { + sessionListener.onOpentelemetryInit = (info) => { + if (info.is_init) { resolve(); } else { - reject(new Error('登录异常' + r?.toString())); + reject(new Error('opentelemetry init failed')); } }; session.init(