chore: storage存储的数据量优化，去掉logs信息

2026-04-14 12:30:54 +08:00 · 2024-12-26 13:48:55 +08:00
parent 246ef348d3
commit b6b7c3e2e0
1 changed files with 7 additions and 1 deletions
--- a/packages/core/pipeline/src/core/executor.ts
+++ b/packages/core/pipeline/src/core/executor.ts
@@ -109,7 +109,13 @@ export class Executor {
    } finally {
      clearInterval(intervalFlushLogId);
      await this.onChanged(this.runtime);
-      await this.pipelineContext.setObj("lastRuntime", this.runtime);
+      //保存之前移除logs
+      const lastRuntime: any = {
+        ...this.runtime,
+      };
+      delete lastRuntime.logs;
+      delete lastRuntime._loggers;
+      await this.pipelineContext.setObj("lastRuntime", lastRuntime);
      this.logger.info(`pipeline.${this.pipeline.id}  end`);
    }
  }