Commit 7569a860 by kay delaney Committed by GitHub

Explore/Loki: Fix handling of legacy log row context request (#21767)

Closes #21695
parent 00fa30f2
...@@ -491,22 +491,26 @@ export class LokiDatasource extends DataSourceApi<LokiQuery, LokiOptions> { ...@@ -491,22 +491,26 @@ export class LokiDatasource extends DataSourceApi<LokiQuery, LokiOptions> {
switchMap((res: { data: LokiStreamResponse; status: number }) => switchMap((res: { data: LokiStreamResponse; status: number }) =>
iif( iif(
() => res.status === 404, () => res.status === 404,
this._request(LEGACY_QUERY_ENDPOINT, target).pipe( defer(() =>
catchError((err: any) => { this._request(LEGACY_QUERY_ENDPOINT, target).pipe(
const error: DataQueryError = { catchError((err: any) => {
message: 'Error during context query. Please check JS console logs.', const error: DataQueryError = {
status: err.status, message: 'Error during context query. Please check JS console logs.',
statusText: err.statusText, status: err.status,
}; statusText: err.statusText,
throw error; };
}), throw error;
map((res: { data: LokiLegacyStreamResponse }) => ({ }),
data: res.data ? res.data.streams.map(stream => legacyLogStreamToDataFrame(stream, reverse)) : [], map((res: { data: LokiLegacyStreamResponse }) => ({
})) data: res.data ? res.data.streams.map(stream => legacyLogStreamToDataFrame(stream, reverse)) : [],
}))
)
), ),
of({ defer(() =>
data: res.data ? res.data.data.result.map(stream => lokiStreamResultToDataFrame(stream, reverse)) : [], of({
}) data: res.data ? res.data.data.result.map(stream => lokiStreamResultToDataFrame(stream, reverse)) : [],
})
)
) )
) )
) )
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment