From 4efb606097ebe39d76734d961706d8cd0e787882 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Sun, 22 Oct 2023 13:42:05 -0400 Subject: [PATCH] update things --- flow/connectors/postgres/qrep_sync_method.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flow/connectors/postgres/qrep_sync_method.go b/flow/connectors/postgres/qrep_sync_method.go index c3776d93dc..09264cbaf3 100644 --- a/flow/connectors/postgres/qrep_sync_method.go +++ b/flow/connectors/postgres/qrep_sync_method.go @@ -72,7 +72,8 @@ func (s *QRepStagingTableSync) SyncQRepRecords( syncRecordsStartTime := time.Now() var numRowsSynced int64 - if writeMode.WriteType == protos.QRepWriteType_QREP_WRITE_MODE_APPEND { + if writeMode == nil || + writeMode.WriteType == protos.QRepWriteType_QREP_WRITE_MODE_APPEND { // Perform the COPY FROM operation numRowsSynced, err = tx.CopyFrom( context.Background(),