fix: stream

Author: astandrik

src/services/api/streaming.ts

@@ -1,7 +1,7 @@
 import {isSessionChunk} from '../../store/reducers/query/utils';
 import type {Actions, TracingLevel} from '../../types/api/query';
 import type {QuerySyntax, StatisticsMode} from '../../types/store/query';
-import type {SessionChunk, StreamingChunk} from '../../types/store/streaming';
+import type {StreamingChunk} from '../../types/store/streaming';
 import {BINARY_DATA_IN_PLAIN_TEXT_DISPLAY} from '../../utils/constants';
 import {MultipartStreamParser} from '../parsers/parseMultipartStream';
 import {settingsManager} from '../settings';
@@ -38,14 +38,8 @@ export class StreamingAPI extends BaseYdbAPI {
 
         const streamParser = new MultipartStreamParser((chunk: StreamingChunk) => {
             if (isSessionChunk(chunk)) {
-                const sessionChunk = chunk as SessionChunk;
-                sessionChunk.meta = {
-                    event: sessionChunk.meta.event,
-                    node_id: sessionChunk.meta.node_id,
-                    query_id: sessionChunk.meta.query_id,
-                    session_id: sessionChunk.meta.session_id,
-                    trace_id: traceId,
-                };
+                const sessionChunk = chunk;
+                sessionChunk.meta.trace_id = traceId;
             }
             options.onChunk(chunk);
         });

src/store/reducers/query/query.ts

@@ -259,7 +259,7 @@ interface QueryStats {
     endTime?: string | number;
 }
 
-const DEFAULT_STREAM_CHUNK_SIZE = 10;
+const DEFAULT_STREAM_CHUNK_SIZE = 100;
 const DEFAULT_CONCURRENT_RESULTS = false;
 
 export const queryApi = api.injectEndpoints({