Skip to content

Commit 1eb3ac2

Browse files
committed
fix: go npe
1 parent 03e5338 commit 1eb3ac2

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

templates/go/ingestion_helpers.mustache

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,15 @@ func (c *APIClient) ChunkedPush(indexName string, objects []map[string]any, acti
6161

6262

6363
if conf.waitForTasks && (len(responses) % 50 == 0 || i == len(objects)-1) {
64-
for _, resp := range responses[:50] {
64+
var waitableResponses []WatchResponse
65+
66+
if len(responses) > 50 {
67+
waitableResponses = responses[len(responses)-50:]
68+
} else {
69+
waitableResponses = responses
70+
}
71+
72+
for _, resp := range waitableResponses {
6573
_, err := CreateIterable( //nolint:wrapcheck
6674
func(*Event, error) (*Event, error) {
6775
if resp.EventID == nil {

0 commit comments

Comments
 (0)