refactor: logs

packages/core/pipeline/src/core/executor.ts

@@ -22,6 +22,7 @@ export class Executor {
     this.onChanged = options.onChanged;
     this.accessService = options.accessService;
     this.userId = options.userId;
+    this.pipeline.userId = this.userId;
     this.contextFactory = new ContextFactory(options.storage);
     this.logger = logger;
     this.pipelineContext = this.contextFactory.getContext("pipeline", this.pipeline.id);

packages/core/pipeline/src/d.ts/pipeline.ts

@@ -64,6 +64,7 @@ export type Runnable = {
 
 export type Pipeline = Runnable & {
   version?: number;
+  userId: any;
   stages: Stage[];
   triggers: Trigger[];
 };