@@ -265,37 +265,37 @@ func TestSmokeLoadWithK6Stream(t *testing.T) {
265
265
DeleteStream (t , NewGlob .QueryClient , NewGlob .Stream )
266
266
}
267
267
268
- func TestSmokeLoad_TimePartition_WithK6Stream (t * testing.T ) {
269
- time_partition_stream := NewGlob .Stream + "timepartition"
270
- timeHeader := map [string ]string {"X-P-Time-Partition" : "source_time" , "X-P-Time-Partition-Limit" : "365d" }
271
- CreateStreamWithHeader (t , NewGlob .QueryClient , time_partition_stream , timeHeader )
272
- if NewGlob .IngestorUrl .String () == "" {
273
- cmd := exec .Command ("k6" ,
274
- "run" ,
275
- "-e" , fmt .Sprintf ("P_URL=%s" , NewGlob .QueryUrl .String ()),
276
- "-e" , fmt .Sprintf ("P_USERNAME=%s" , NewGlob .QueryUsername ),
277
- "-e" , fmt .Sprintf ("P_PASSWORD=%s" , NewGlob .QueryPassword ),
278
- "-e" , fmt .Sprintf ("P_STREAM=%s" , time_partition_stream ),
279
- "./scripts/smoke.js" )
280
-
281
- cmd .Run ()
282
- cmd .Output ()
283
- } else {
284
- cmd := exec .Command ("k6" ,
285
- "run" ,
286
- "-e" , fmt .Sprintf ("P_URL=%s" , NewGlob .IngestorUrl .String ()),
287
- "-e" , fmt .Sprintf ("P_USERNAME=%s" , NewGlob .IngestorUsername ),
288
- "-e" , fmt .Sprintf ("P_PASSWORD=%s" , NewGlob .IngestorPassword ),
289
- "-e" , fmt .Sprintf ("P_STREAM=%s" , time_partition_stream ),
290
- "./scripts/smoke.js" )
291
-
292
- cmd .Run ()
293
- cmd .Output ()
294
- }
295
- time .Sleep (120 * time .Second )
296
- QueryLogStreamCount_Historical (t , NewGlob .QueryClient , time_partition_stream , 20000 )
297
- DeleteStream (t , NewGlob .QueryClient , time_partition_stream )
298
- }
268
+ // func TestSmokeLoad_TimePartition_WithK6Stream(t *testing.T) {
269
+ // time_partition_stream := NewGlob.Stream + "timepartition"
270
+ // timeHeader := map[string]string{"X-P-Time-Partition": "source_time", "X-P-Time-Partition-Limit": "365d"}
271
+ // CreateStreamWithHeader(t, NewGlob.QueryClient, time_partition_stream, timeHeader)
272
+ // if NewGlob.IngestorUrl.String() == "" {
273
+ // cmd := exec.Command("k6",
274
+ // "run",
275
+ // "-e", fmt.Sprintf("P_URL=%s", NewGlob.QueryUrl.String()),
276
+ // "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.QueryUsername),
277
+ // "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.QueryPassword),
278
+ // "-e", fmt.Sprintf("P_STREAM=%s", time_partition_stream),
279
+ // "./scripts/smoke.js")
280
+
281
+ // cmd.Run()
282
+ // cmd.Output()
283
+ // } else {
284
+ // cmd := exec.Command("k6",
285
+ // "run",
286
+ // "-e", fmt.Sprintf("P_URL=%s", NewGlob.IngestorUrl.String()),
287
+ // "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.IngestorUsername),
288
+ // "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.IngestorPassword),
289
+ // "-e", fmt.Sprintf("P_STREAM=%s", time_partition_stream),
290
+ // "./scripts/smoke.js")
291
+
292
+ // cmd.Run()
293
+ // cmd.Output()
294
+ // }
295
+ // time.Sleep(120 * time.Second)
296
+ // QueryLogStreamCount_Historical(t, NewGlob.QueryClient, time_partition_stream, 20000)
297
+ // DeleteStream(t, NewGlob.QueryClient, time_partition_stream)
298
+ // }
299
299
300
300
func TestSmokeLoad_CustomPartition_WithK6Stream (t * testing.T ) {
301
301
custom_partition_stream := NewGlob .Stream + "custompartition"
0 commit comments