(cherry picked from commit a0e5a4eba2)
Co-authored-by: Gábor Farkas <gabor.farkas@gmail.com>
This commit is contained in:
co-authored by
Gábor Farkas
parent
98c540f51e
commit
b4dba8d14e
@@ -702,7 +702,17 @@ export function queryLogsVolume<T extends DataQuery>(
|
||||
observer.complete();
|
||||
},
|
||||
next: (dataQueryResponse: DataQueryResponse) => {
|
||||
rawLogsVolume = rawLogsVolume.concat(dataQueryResponse.data.map(toDataFrame));
|
||||
const { error } = dataQueryResponse;
|
||||
if (error !== undefined) {
|
||||
observer.next({
|
||||
state: LoadingState.Error,
|
||||
error,
|
||||
data: [],
|
||||
});
|
||||
observer.error(error);
|
||||
} else {
|
||||
rawLogsVolume = rawLogsVolume.concat(dataQueryResponse.data.map(toDataFrame));
|
||||
}
|
||||
},
|
||||
error: (error) => {
|
||||
observer.next({
|
||||
|
||||
Reference in New Issue
Block a user