From 69621f8e5e18c1f731d92bd45b56bbcea267f241 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Wed, 6 Dec 2023 02:12:44 +0530 Subject: [PATCH] change var name --- flow/connectors/utils/monitoring/monitoring.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flow/connectors/utils/monitoring/monitoring.go b/flow/connectors/utils/monitoring/monitoring.go index ad8457bd38..2afcdce5c8 100644 --- a/flow/connectors/utils/monitoring/monitoring.go +++ b/flow/connectors/utils/monitoring/monitoring.go @@ -306,14 +306,14 @@ func (c *CatalogMirrorMonitor) UpdateStartTimeForPartition( ctx context.Context, runUUID string, partition *protos.QRepPartition, - specificTime *time.Time, + overrideStartTime *time.Time, ) error { if c == nil || c.catalogConn == nil { return nil } startTime := time.Now() - if specificTime != nil { - startTime = *specificTime + if overrideStartTime != nil { + startTime = *overrideStartTime } _, err := c.catalogConn.Exec(ctx, `UPDATE peerdb_stats.qrep_partitions SET start_time=$1