diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go index fdec9d15c6..10757774d6 100644 --- a/flow/workflows/snapshot_flow.go +++ b/flow/workflows/snapshot_flow.go @@ -199,6 +199,7 @@ func (s *SnapshotFlowExecution) cloneTable( SoftDeleteColName: s.config.SoftDeleteColName, WriteMode: snapshotWriteMode, System: s.config.System, + Script: s.config.Script, } state := NewQRepFlowState()