From 3d01e8dc0abd91ed3c33b0409e107516b15d99f8 Mon Sep 17 00:00:00 2001 From: Lukas Malkmus Date: Tue, 12 Sep 2023 18:04:30 +0200 Subject: [PATCH] fix(ingest): respect ingest options specified by flag --- internal/cmd/ingest/ingest.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/cmd/ingest/ingest.go b/internal/cmd/ingest/ingest.go index 1d30d66..48dabe8 100644 --- 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...)