@@ -259,7 +259,7 @@ func TestSmokeLoadWithK6Stream(t *testing.T) {
259
259
cmd .Run ()
260
260
cmd .Output ()
261
261
}
262
- time .Sleep (120 * time .Second )
262
+ time .Sleep (150 * time .Second )
263
263
QueryLogStreamCount (t , NewGlob .QueryClient , NewGlob .Stream , 20000 )
264
264
AssertStreamSchema (t , NewGlob .QueryClient , NewGlob .Stream , SchemaBody )
265
265
DeleteStream (t , NewGlob .QueryClient , NewGlob .Stream )
@@ -329,37 +329,37 @@ func TestSmokeLoad_CustomPartition_WithK6Stream(t *testing.T) {
329
329
DeleteStream (t , NewGlob .QueryClient , custom_partition_stream )
330
330
}
331
331
332
- func TestSmokeLoad_TimeAndCustomPartition_WithK6Stream (t * testing.T ) {
333
- custom_partition_stream := NewGlob .Stream + "timecustompartition"
334
- customHeader := map [string ]string {"X-P-Custom-Partition" : "level" , "X-P-Time-Partition" : "source_time" , "X-P-Time-Partition-Limit" : "365d" }
335
- CreateStreamWithHeader (t , NewGlob .QueryClient , custom_partition_stream , customHeader )
336
- if NewGlob .IngestorUrl .String () == "" {
337
- cmd := exec .Command ("k6" ,
338
- "run" ,
339
- "-e" , fmt .Sprintf ("P_URL=%s" , NewGlob .QueryUrl .String ()),
340
- "-e" , fmt .Sprintf ("P_USERNAME=%s" , NewGlob .QueryUsername ),
341
- "-e" , fmt .Sprintf ("P_PASSWORD=%s" , NewGlob .QueryPassword ),
342
- "-e" , fmt .Sprintf ("P_STREAM=%s" , custom_partition_stream ),
343
- "./scripts/smoke.js" )
332
+ // func TestSmokeLoad_TimeAndCustomPartition_WithK6Stream(t *testing.T) {
333
+ // custom_partition_stream := NewGlob.Stream + "timecustompartition"
334
+ // customHeader := map[string]string{"X-P-Custom-Partition": "level", "X-P-Time-Partition": "source_time", "X-P-Time-Partition-Limit": "365d"}
335
+ // CreateStreamWithHeader(t, NewGlob.QueryClient, custom_partition_stream, customHeader)
336
+ // if NewGlob.IngestorUrl.String() == "" {
337
+ // cmd := exec.Command("k6",
338
+ // "run",
339
+ // "-e", fmt.Sprintf("P_URL=%s", NewGlob.QueryUrl.String()),
340
+ // "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.QueryUsername),
341
+ // "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.QueryPassword),
342
+ // "-e", fmt.Sprintf("P_STREAM=%s", custom_partition_stream),
343
+ // "./scripts/smoke.js")
344
344
345
- cmd .Run ()
346
- cmd .Output ()
347
- } else {
348
- cmd := exec .Command ("k6" ,
349
- "run" ,
350
- "-e" , fmt .Sprintf ("P_URL=%s" , NewGlob .IngestorUrl .String ()),
351
- "-e" , fmt .Sprintf ("P_USERNAME=%s" , NewGlob .IngestorUsername ),
352
- "-e" , fmt .Sprintf ("P_PASSWORD=%s" , NewGlob .IngestorPassword ),
353
- "-e" , fmt .Sprintf ("P_STREAM=%s" , custom_partition_stream ),
354
- "./scripts/smoke.js" )
345
+ // cmd.Run()
346
+ // cmd.Output()
347
+ // } else {
348
+ // cmd := exec.Command("k6",
349
+ // "run",
350
+ // "-e", fmt.Sprintf("P_URL=%s", NewGlob.IngestorUrl.String()),
351
+ // "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.IngestorUsername),
352
+ // "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.IngestorPassword),
353
+ // "-e", fmt.Sprintf("P_STREAM=%s", custom_partition_stream),
354
+ // "./scripts/smoke.js")
355
355
356
- cmd .Run ()
357
- cmd .Output ()
358
- }
359
- time .Sleep (180 * time .Second )
360
- QueryLogStreamCount_Historical (t , NewGlob .QueryClient , custom_partition_stream , 20000 )
361
- DeleteStream (t , NewGlob .QueryClient , custom_partition_stream )
362
- }
356
+ // cmd.Run()
357
+ // cmd.Output()
358
+ // }
359
+ // time.Sleep(180 * time.Second)
360
+ // QueryLogStreamCount_Historical(t, NewGlob.QueryClient, custom_partition_stream, 20000)
361
+ // DeleteStream(t, NewGlob.QueryClient, custom_partition_stream)
362
+ // }
363
363
364
364
func TestSmokeSetAlert (t * testing.T ) {
365
365
CreateStream (t , NewGlob .QueryClient , NewGlob .Stream )
0 commit comments