diff --git a/go/libraries/doltcore/sqle/read_replica_database.go b/go/libraries/doltcore/sqle/read_replica_database.go index 08d9015b52..871800a367 100644 --- a/go/libraries/doltcore/sqle/read_replica_database.go +++ b/go/libraries/doltcore/sqle/read_replica_database.go @@ -379,6 +379,9 @@ func pullBranches( _, err := rrd.limiter.Run(ctx, "-all", func() (any, error) { pullErr := rrd.ddb.PullChunks(ctx, rrd.tmpDir, rrd.srcDB, remoteHashes, nil) + if pullErr != nil { + return nil, pullErr + } REFS: // every successful pass through the loop below must end with CONTINUE REFS to get out of the retry loop for _, remoteRef := range remoteRefs {