src/app/jobs/model/step-execution.model.ts
Contains information about a specific step execution.
Properties |
|
Methods |
|
| Static fromJSON | ||||||||
fromJSON(input: )
|
||||||||
|
Parameters :
Returns :
StepExecution
|
| Public commitCount |
commitCount:
|
Type : number
|
| Public endTime |
endTime:
|
Type : DateTime
|
| Public executionContext |
executionContext:
|
Type : ExecutionContext
|
| Public exitCode |
exitCode:
|
Type : string
|
| Public exitMessage |
exitMessage:
|
Type : string
|
| Public filterCount |
filterCount:
|
Type : number
|
| Public id |
id:
|
Type : string
|
|
Defined in src/app/jobs/model/step-execution.model.ts:9
|
| Public name |
name:
|
Type : string
|
| Public processSkipCount |
processSkipCount:
|
Type : number
|
| Public readCount |
readCount:
|
Type : number
|
| Public readSkipCount |
readSkipCount:
|
Type : number
|
| Public rollbackCount |
rollbackCount:
|
Type : number
|
| Public skipCount |
skipCount:
|
Type : number
|
| Public startTime |
startTime:
|
Type : DateTime
|
| Public status |
status:
|
Type : string
|
| Public writeCount |
writeCount:
|
Type : number
|
| Public writeSkipCount |
writeSkipCount:
|
Type : number
|
import { ExecutionContext } from './execution-context.model';
import { DateTime } from 'luxon';
/**
* Contains information about a specific step execution.
* @author Janne Valkealahti
*/
export class StepExecution {
public id: string;
public name: string;
public status: string;
public readCount: number;
public writeCount: number;
public commitCount: number;
public rollbackCount: number;
public readSkipCount: number;
public processSkipCount: number;
public writeSkipCount: number;
public filterCount: number;
public skipCount: number;
public startTime: DateTime;
public endTime: DateTime;
public executionContext: ExecutionContext;
public exitCode: string;
public exitMessage: string;
static fromJSON(input) {
const stepExecution: StepExecution = new StepExecution();
stepExecution.id = input.id;
stepExecution.name = input.stepName;
stepExecution.status = input.status;
stepExecution.readCount = input.readCount;
stepExecution.writeCount = input.writeCount;
stepExecution.commitCount = input.commitCount;
stepExecution.rollbackCount = input.rollbackCount;
stepExecution.readSkipCount = input.readSkipCount;
stepExecution.processSkipCount = input.processSkipCount;
stepExecution.writeSkipCount = input.writeSkipCount;
stepExecution.filterCount = input.filterCount;
stepExecution.skipCount = input.skipCount;
stepExecution.startTime = DateTime.fromISO(input.startTime);
stepExecution.endTime = DateTime.fromISO(input.endTime);
if (input.executionContext) {
const values = new Array<Map<string, string>>();
input.executionContext.values.forEach(item => {
const map = new Map<string, string>();
for (const prop in item) {
if (item.hasOwnProperty(prop)) {
map.set(prop, item[prop]);
}
}
values.push(map);
});
stepExecution.executionContext = new ExecutionContext(
input.executionContext.dirty,
input.executionContext.empty,
values);
}
if (input.exitStatus) {
stepExecution.exitCode = input.exitStatus.exitCode;
stepExecution.exitMessage = input.exitStatus.exitDescription;
}
return stepExecution;
}
}