Changeset View
Changeset View
Standalone View
Standalone View
js_modules/dagit/packages/core/src/runs/LogsProvider.tsx
Show First 20 Lines • Show All 121 Lines • ▼ Show 20 Lines | for (const msg of messages) { | ||||
} else if (__typename === 'PipelineStartingEvent') { | } else if (__typename === 'PipelineStartingEvent') { | ||||
nextPipelineStatus = PipelineRunStatus.STARTING; | nextPipelineStatus = PipelineRunStatus.STARTING; | ||||
} else if (__typename === 'PipelineCancelingEvent') { | } else if (__typename === 'PipelineCancelingEvent') { | ||||
nextPipelineStatus = PipelineRunStatus.CANCELING; | nextPipelineStatus = PipelineRunStatus.CANCELING; | ||||
} else if (__typename === 'PipelineCanceledEvent') { | } else if (__typename === 'PipelineCanceledEvent') { | ||||
nextPipelineStatus = PipelineRunStatus.CANCELED; | nextPipelineStatus = PipelineRunStatus.CANCELED; | ||||
} else if (__typename === 'PipelineSuccessEvent') { | } else if (__typename === 'PipelineSuccessEvent') { | ||||
nextPipelineStatus = PipelineRunStatus.SUCCESS; | nextPipelineStatus = PipelineRunStatus.SUCCESS; | ||||
} else if ( | } else if (__typename === 'PipelineFailureEvent') { | ||||
__typename === 'PipelineFailureEvent' || | |||||
__typename === 'PipelineInitFailureEvent' | |||||
) { | |||||
nextPipelineStatus = PipelineRunStatus.FAILURE; | nextPipelineStatus = PipelineRunStatus.FAILURE; | ||||
} | } | ||||
} | } | ||||
} | } | ||||
if (nextPipelineStatus) { | if (nextPipelineStatus) { | ||||
this.syncPipelineStatusToApolloCache(nextPipelineStatus); | this.syncPipelineStatusToApolloCache(nextPipelineStatus); | ||||
} | } | ||||
▲ Show 20 Lines • Show All 171 Lines • Show Last 20 Lines |