[Reporting] don’t wait for refresh when uploading a chunk (elastic#20…

…4775) ## Summary close elastic/kibana-team#1367 We saw significant slowness when uploading large CSV files in serverless. This PR should speed this up. Initially wait_for was introduced to reduce test flakiness elastic#176022 (comment), but it seems it can be safely removed from uploading stream chunks Co-authored-by: Elastic Machine <[email protected]>
tsullivan · Jan 2, 2025 · 6a84ccc · 6a84ccc
1 parent a0c94f4
commit 6a84ccc
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/x-pack/plugins/reporting/server/lib/content_stream.test.ts b/x-pack/plugins/reporting/server/lib/content_stream.test.ts
@@ -300,7 +300,6 @@ describe('ContentStream', () => {
           id: expect.any(String),
           index: '.kibana-reporting',
           op_type: 'create',
-          refresh: 'wait_for',
           body: {
             '@timestamp': '1970-01-01T00:00:00.000Z',
             parent_id: 'something',
@@ -317,7 +316,6 @@ describe('ContentStream', () => {
           id: expect.any(String),
           index: '.kibana-reporting',
           op_type: 'create',
-          refresh: 'wait_for',
           body: {
             '@timestamp': '1970-01-01T00:00:00.000Z',
             parent_id: 'something',
@@ -348,7 +346,6 @@ describe('ContentStream', () => {
           id: expect.any(String),
           index: '.kibana-reporting',
           op_type: 'create',
-          refresh: 'wait_for',
           body: {
             parent_id: 'something',
             '@timestamp': '1970-01-01T00:00:00.000Z',
@@ -365,7 +362,6 @@ describe('ContentStream', () => {
           id: expect.any(String),
           index: '.kibana-reporting',
           op_type: 'create',
-          refresh: 'wait_for',
           body: {
             parent_id: 'something',
             '@timestamp': '1970-01-01T00:00:00.000Z',

diff --git a/x-pack/plugins/reporting/server/lib/content_stream.ts b/x-pack/plugins/reporting/server/lib/content_stream.ts
@@ -192,7 +192,6 @@ export class ContentStream extends Duplex {
 
     const body = await this.client.update<ReportSource>({
       ...this.document,
-      refresh: 'wait_for',
       body: {
         doc: {
           output: { content },
@@ -212,7 +211,6 @@ export class ContentStream extends Duplex {
     await this.client.index<ChunkSource>({
       id,
       index: REPORTING_DATA_STREAM_ALIAS,
-      refresh: 'wait_for',
       op_type: 'create',
       body: {
         parent_id: parentId,