fix(ingest): respect ingest options specified by flag

axiomhq · Sep 12, 2023 · 3d01e8d · 3d01e8d
1 parent 99ca589
commit 3d01e8d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/cmd/ingest/ingest.go b/internal/cmd/ingest/ingest.go
@@ -442,13 +442,13 @@ func ingestReader(ctx context.Context, client *axiom.Client, r io.Reader, typ ax
 
 	ingestOptions := make([]ingest.Option, 0)
 	if v := opts.TimestampField; v != "" {
-		ingest.SetTimestampField(v)
+		ingestOptions = append(ingestOptions, ingest.SetTimestampField(v))
 	}
 	if v := opts.TimestampFormat; v != "" {
-		ingest.SetTimestampFormat(v)
+		ingestOptions = append(ingestOptions, ingest.SetTimestampFormat(v))
 	}
 	if v := opts.Delimiter; v != "" {
-		ingest.SetCSVDelimiter(v)
+		ingestOptions = append(ingestOptions, ingest.SetCSVDelimiter(v))
 	}
 	ingestOptions = append(ingestOptions, opts.Labels...)