github
/
certd
mirror of https://github.com/certd/certd
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore:

pull/21/merge
xiaojunnuo 2023-07-10 13:57:26 +08:00
parent 28449c348e
commit 4d3c86dba1
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/core/pipeline/src/core/executor.ts
View File

@ -189,6 +189,8 @@ export class Executor {
} }
private async runStep(step: Step) { private async runStep(step: Step) {
const currentLogger = this.runtime._loggers[step.id];
const lastStatus = this.lastStatusMap.get(step.id); const lastStatus = this.lastStatusMap.get(step.id);
//执行任务 //执行任务
const plugin: RegistryItem<AbstractTaskPlugin> = pluginRegistry.get(step.type); const plugin: RegistryItem<AbstractTaskPlugin> = pluginRegistry.get(step.type);
@ -202,7 +204,11 @@ export class Executor {
if (item.component?.name === "pi-output-selector") { if (item.component?.name === "pi-output-selector") {
const contextKey = step.input[key]; const contextKey = step.input[key];
if (contextKey != null) { if (contextKey != null) {
step.input[key] = this.runtime.context[contextKey]; const value = this.runtime.context[contextKey];
if (value == null) {
currentLogger.warn(`[step init] input ${define.title} is null`);
}
step.input[key] = value;
} }
} }
}); });
@ -212,7 +218,7 @@ export class Executor {
step, step,
lastStatus, lastStatus,
http: request, http: request,
logger: this.runtime._loggers[step.id], logger: currentLogger,
accessService: this.options.accessService, accessService: this.options.accessService,
emailService: this.options.emailService, emailService: this.options.emailService,
pipelineContext: this.pipelineContext, pipelineContext: this.pipelineContext,