@@ -46,8 +46,8 @@ func registerJobs(r registry.Registry) {
4646 Name : "jobs/stress" ,
4747 Owner : registry .OwnerDisasterRecovery ,
4848 Cluster : jobsSpec ,
49+ Benchmark : true ,
4950 EncryptionSupport : registry .EncryptionMetamorphic ,
50- Leases : registry .MetamorphicLeases ,
5151 CompatibleClouds : registry .OnlyGCE ,
5252 Suites : registry .Suites (registry .Nightly ),
5353 Timeout : roachtestTimeout ,
@@ -120,9 +120,9 @@ func runJobsStress(ctx context.Context, t test.Test, c cluster.Cluster) {
120120 }
121121 }
122122 }
123- for i := 0 ; i < nodeCount ; i ++ {
124- group .Go (randomPoller (time .Second , checkJobQueryLatency ))
125- }
123+ // for i := 0; i < nodeCount; i++ {
124+ // group.Go(randomPoller(time.Second, checkJobQueryLatency))
125+ // }
126126
127127 waitTime := time .Duration (rng .Intn (pollerMinFrequencySeconds )+ 1 ) * time .Second
128128 jobIDToTableName := make (map [jobspb.JobID ]string )
@@ -145,6 +145,7 @@ func runJobsStress(ctx context.Context, t test.Test, c cluster.Cluster) {
145145
146146 require .NoError (t , group .WaitE ())
147147 checkJobSystemHealth (ctx , t , c , rng )
148+ require .NoError (t , checkJobQueryLatency (ctx , t , c , rng ))
148149}
149150
150151func createTablesWithChangefeeds (
0 commit comments