fix(streamingbatchwriter): Missing tickerFn on DeleteWorker (#1103)

disq · web-flow · commit 91eae5652658 · 2023-07-18T14:27:27.000+01:00
Co-authored-by: Kemal Hadimli &lt;disq@users.noreply.github.com&gt;
diff --git a/writers/streamingbatchwriter/streamingbatchwriter.go b/writers/streamingbatchwriter/streamingbatchwriter.go
@@ -248,6 +248,7 @@ func (w *StreamingBatchWriter) startWorker(ctx context.Context, errCh chan<- err
 
 			batchSizeRows: w.batchSizeRows,
 			batchTimeout:  w.batchTimeout,
+			tickerFn:      w.tickerFn,
 		}
 
 		w.workersWaitGroup.Add(1)

Original file line number	Diff line number	Diff line change
`@@ -248,6 +248,7 @@ func (w *StreamingBatchWriter) startWorker(ctx context.Context, errCh chan<- err`
`248`	`248`
`249`	`249`	`batchSizeRows: w.batchSizeRows,`
`250`	`250`	`batchTimeout: w.batchTimeout,`
	`251`	`+ tickerFn: w.tickerFn,`
`251`	`252`	`}`
`252`	`253`
`253`	`254`	`w.workersWaitGroup.Add(1)`