Changeset View
Changeset View
Standalone View
Standalone View
js_modules/dagit/packages/core/src/runs/RunMetadataProvider.tsx
| Show First 20 Lines • Show All 57 Lines • ▼ Show 20 Lines | |||||
| export interface IRunMetadataDict { | export interface IRunMetadataDict { | ||||
| firstLogAt: number; | firstLogAt: number; | ||||
| mostRecentLogAt: number; | mostRecentLogAt: number; | ||||
| startingProcessAt?: number; | startingProcessAt?: number; | ||||
| startedProcessAt?: number; | startedProcessAt?: number; | ||||
| startedPipelineAt?: number; | startedPipelineAt?: number; | ||||
| exitedAt?: number; | exitedAt?: number; | ||||
| processId?: number; | processId?: number; | ||||
| initFailed?: boolean; | |||||
| globalMarkers: IMarker[]; | globalMarkers: IMarker[]; | ||||
| steps: { | steps: { | ||||
| [stepKey: string]: IStepMetadata; | [stepKey: string]: IStepMetadata; | ||||
| }; | }; | ||||
| logCaptureSteps?: { | logCaptureSteps?: { | ||||
| [logKey: string]: ILogCaptureInfo; | [logKey: string]: ILogCaptureInfo; | ||||
| }; | }; | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 45 Lines • ▼ Show 20 Lines | logs.forEach((log) => { | ||||
| metadata.firstLogAt = metadata.firstLogAt | metadata.firstLogAt = metadata.firstLogAt | ||||
| ? Math.min(metadata.firstLogAt, timestamp) | ? Math.min(metadata.firstLogAt, timestamp) | ||||
| : timestamp; | : timestamp; | ||||
| metadata.mostRecentLogAt = Math.max(metadata.mostRecentLogAt, timestamp); | metadata.mostRecentLogAt = Math.max(metadata.mostRecentLogAt, timestamp); | ||||
| if (log.__typename === 'PipelineStartEvent') { | if (log.__typename === 'PipelineStartEvent') { | ||||
| metadata.startedPipelineAt = timestamp; | metadata.startedPipelineAt = timestamp; | ||||
| } | } | ||||
| if (log.__typename === 'PipelineInitFailureEvent') { | |||||
| metadata.initFailed = true; | |||||
| metadata.exitedAt = timestamp; | |||||
| } | |||||
| if ( | if ( | ||||
| log.__typename === 'PipelineFailureEvent' || | log.__typename === 'PipelineFailureEvent' || | ||||
| log.__typename === 'PipelineSuccessEvent' || | log.__typename === 'PipelineSuccessEvent' || | ||||
| log.__typename === 'PipelineCanceledEvent' | log.__typename === 'PipelineCanceledEvent' | ||||
| ) { | ) { | ||||
| metadata.exitedAt = timestamp; | metadata.exitedAt = timestamp; | ||||
| for (const step of Object.values(metadata.steps)) { | for (const step of Object.values(metadata.steps)) { | ||||
| if (step.state === IStepState.RUNNING) { | if (step.state === IStepState.RUNNING) { | ||||
| ▲ Show 20 Lines • Show All 142 Lines • Show Last 20 Lines | |||||