Less intrusive fix

crate · Dec 27, 2023 · 93769a1 · 93769a1
1 parent 0d7f56e
commit 93769a1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/crate.go b/crate.go
@@ -164,10 +164,11 @@ func (c crateEndpoint) write(ctx context.Context, r *crateWriteRequest) error {
 	batch := &pgx.Batch{}
 	for _, a := range r.rows {
 		batch.Queue(
-			crateWriteStatement,
+			"write_statement",
 			a.labels,
 			a.labelsHash,
-			a.timestamp,
+			// TODO: Find non-string way of encoding timestamps.
+			a.timestamp.Format("2006-01-02 15:04:05.000-07"),
 			a.value,
 			a.valueRaw,
 		)