From 5104b00a6042998c8a3012854af8e9d575a3b42c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Tue, 7 May 2024 13:25:52 +0000 Subject: [PATCH] fix ci (#1678) regression in #1667 that wasn't caught because CI doesn't work for external PRs --- flow/workflows/qrep_flow.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go index a988e1f96c..8be2619866 100644 --- a/flow/workflows/qrep_flow.go +++ b/flow/workflows/qrep_flow.go @@ -570,7 +570,7 @@ func QRepFlowWorkflow( return err } - if state.LastPartition != nil { + if !config.InitialCopyOnly && state.LastPartition != nil { if err := q.waitForNewRows(ctx, signalChan, state.LastPartition); err != nil { return err }