diff --git a/pkg/cmd/roachtest/tests/tpch_concurrency.go b/pkg/cmd/roachtest/tests/tpch_concurrency.go index 04d17de297c7..79c2fc8b0d03 100644 --- a/pkg/cmd/roachtest/tests/tpch_concurrency.go +++ b/pkg/cmd/roachtest/tests/tpch_concurrency.go @@ -118,7 +118,7 @@ func registerTPCHConcurrency(r registry.Registry) { // diagram of the query. rows, err := conn.Query("EXPLAIN (DISTSQL) " + tpch.QueriesByNumber[queryNum]) if err != nil { - t.Fatal(err) + return err } defer rows.Close() for rows.Next() {