timestamptz, use json

PeerDB-io · Jan 31, 2024 · 15b9be2 · 15b9be2
1 parent 45bd19e
commit 15b9be2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/flow/connectors/external_metadata/store.go b/flow/connectors/external_metadata/store.go
@@ -124,7 +124,7 @@ func (p *PostgresMetadataStore) SetupMetadata() error {
 		CREATE TABLE IF NOT EXISTS `+p.QualifyTable(lastSyncStateTableName)+`(
 			job_name TEXT PRIMARY KEY NOT NULL,
 			last_offset BIGINT NOT NULL,
-			updated_at TIMESTAMP NOT NULL DEFAULT NOW(),
+			updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
 			sync_batch_id BIGINT NOT NULL,
 			normalize_batch_id BIGINT
 		)`)
@@ -137,9 +137,9 @@ func (p *PostgresMetadataStore) SetupMetadata() error {
 		CREATE TABLE IF NOT EXISTS `+p.QualifyTable(qrepTableName)+`(
 			job_name TEXT NOT NULL,
 			partition_id TEXT NOT NULL,
-			sync_partition TEXT NOT NULL,
-			sync_start_time TIMESTAMP NOT NULL,
-			sync_finish_time TIMESTAMP NOT NULL DEFAULT NOW()
+			sync_partition JSON NOT NULL,
+			sync_start_time TIMESTAMPTZ NOT NULL,
+			sync_finish_time TIMESTAMPTZ NOT NULL DEFAULT NOW()
 		)`)
 	if err != nil && !utils.IsUniqueError(err) {
 		p.logger.Error("failed to create qrep metadata table", slog.Any("error", err))