diff --git a/internal/cmd/ingest/ingest.go b/internal/cmd/ingest/ingest.go index 48dabe8..b5f22b4 100644 --- a/internal/cmd/ingest/ingest.go +++ b/internal/cmd/ingest/ingest.go @@ -378,6 +378,7 @@ func ingestEvery(ctx context.Context, client *axiom.Client, r io.Reader, opts *o _ = pw.CloseWithError(ctx.Err()) return default: + time.Sleep(time.Millisecond) } if !scanner.Scan() { @@ -411,6 +412,8 @@ func ingestEvery(ctx context.Context, client *axiom.Client, r io.Reader, opts *o case <-done: _ = pw.Close() return + default: + time.Sleep(time.Millisecond) } } }()