Skip to content

Commit 5a0697b

Browse files
nikhilsinhaparseablenikhilsinhaparseable
authored
remove time partition tests (#98)
1 parent a2acf37 commit 5a0697b

File tree

1 file changed

+127
-127
lines changed

1 file changed

+127
-127
lines changed

‎quest_test.go

+127-127
Original file line numberDiff line numberDiff line change
@@ -80,41 +80,41 @@ func TestSmokeIngestEventsToStream(t *testing.T) {
8080
DeleteStream(t, NewGlob.QueryClient, NewGlob.Stream)
8181
}
8282

83-
func TestTimePartition_TimeStampMismatch(t *testing.T) {
84-
historicalStream := NewGlob.Stream + "historical"
85-
timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
86-
CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
87-
if NewGlob.IngestorUrl.String() == "" {
88-
IngestOneEventWithTimePartition_TimeStampMismatch(t, NewGlob.QueryClient, historicalStream)
89-
} else {
90-
IngestOneEventWithTimePartition_TimeStampMismatch(t, NewGlob.IngestorClient, historicalStream)
91-
}
92-
DeleteStream(t, NewGlob.QueryClient, historicalStream)
93-
}
83+
// func TestTimePartition_TimeStampMismatch(t *testing.T) {
84+
// historicalStream := NewGlob.Stream + "historical"
85+
// timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
86+
// CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
87+
// if NewGlob.IngestorUrl.String() == "" {
88+
// IngestOneEventWithTimePartition_TimeStampMismatch(t, NewGlob.QueryClient, historicalStream)
89+
// } else {
90+
// IngestOneEventWithTimePartition_TimeStampMismatch(t, NewGlob.IngestorClient, historicalStream)
91+
// }
92+
// DeleteStream(t, NewGlob.QueryClient, historicalStream)
93+
// }
9494

95-
func TestTimePartition_NoTimePartitionInLog(t *testing.T) {
96-
historicalStream := NewGlob.Stream + "historical"
97-
timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
98-
CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
99-
if NewGlob.IngestorUrl.String() == "" {
100-
IngestOneEventWithTimePartition_NoTimePartitionInLog(t, NewGlob.QueryClient, historicalStream)
101-
} else {
102-
IngestOneEventWithTimePartition_NoTimePartitionInLog(t, NewGlob.IngestorClient, historicalStream)
103-
}
104-
DeleteStream(t, NewGlob.QueryClient, historicalStream)
105-
}
95+
// func TestTimePartition_NoTimePartitionInLog(t *testing.T) {
96+
// historicalStream := NewGlob.Stream + "historical"
97+
// timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
98+
// CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
99+
// if NewGlob.IngestorUrl.String() == "" {
100+
// IngestOneEventWithTimePartition_NoTimePartitionInLog(t, NewGlob.QueryClient, historicalStream)
101+
// } else {
102+
// IngestOneEventWithTimePartition_NoTimePartitionInLog(t, NewGlob.IngestorClient, historicalStream)
103+
// }
104+
// DeleteStream(t, NewGlob.QueryClient, historicalStream)
105+
// }
106106

107-
func TestTimePartition_IncorrectDateTimeFormatTimePartitionInLog(t *testing.T) {
108-
historicalStream := NewGlob.Stream + "historical"
109-
timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
110-
CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
111-
if NewGlob.IngestorUrl.String() == "" {
112-
IngestOneEventWithTimePartition_IncorrectDateTimeFormatTimePartitionInLog(t, NewGlob.QueryClient, historicalStream)
113-
} else {
114-
IngestOneEventWithTimePartition_IncorrectDateTimeFormatTimePartitionInLog(t, NewGlob.IngestorClient, historicalStream)
115-
}
116-
DeleteStream(t, NewGlob.QueryClient, historicalStream)
117-
}
107+
// func TestTimePartition_IncorrectDateTimeFormatTimePartitionInLog(t *testing.T) {
108+
// historicalStream := NewGlob.Stream + "historical"
109+
// timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
110+
// CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
111+
// if NewGlob.IngestorUrl.String() == "" {
112+
// IngestOneEventWithTimePartition_IncorrectDateTimeFormatTimePartitionInLog(t, NewGlob.QueryClient, historicalStream)
113+
// } else {
114+
// IngestOneEventWithTimePartition_IncorrectDateTimeFormatTimePartitionInLog(t, NewGlob.IngestorClient, historicalStream)
115+
// }
116+
// DeleteStream(t, NewGlob.QueryClient, historicalStream)
117+
// }
118118

119119
func TestLoadStream_StaticSchema_EventWithSameFields(t *testing.T) {
120120
staticSchemaStream := NewGlob.Stream + "staticschema"
@@ -562,54 +562,54 @@ func TestLoadStreamBatchWithK6(t *testing.T) {
562562
}
563563
}
564564

565-
func TestLoadHistoricalStreamBatchWithK6(t *testing.T) {
566-
if NewGlob.Mode == "load" {
567-
historicalStream := NewGlob.Stream + "historical"
568-
timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
569-
CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
570-
if NewGlob.IngestorUrl.String() == "" {
571-
cmd := exec.Command("k6",
572-
"run",
573-
"-e", fmt.Sprintf("P_URL=%s", NewGlob.QueryUrl.String()),
574-
"-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.QueryUsername),
575-
"-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.QueryPassword),
576-
"-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
577-
"-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
578-
"-e", fmt.Sprintf("P_EVENTS_COUNT=%s", events_count),
579-
"./scripts/load_historical_batch_events.js",
580-
"--vus=", vus,
581-
"--duration=", duration)
582-
583-
cmd.Run()
584-
op, err := cmd.Output()
585-
if err != nil {
586-
t.Log(err)
587-
}
588-
t.Log(string(op))
589-
} else {
590-
cmd := exec.Command("k6",
591-
"run",
592-
"-e", fmt.Sprintf("P_URL=%s", NewGlob.IngestorUrl.String()),
593-
"-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.IngestorUsername),
594-
"-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.IngestorPassword),
595-
"-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
596-
"-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
597-
"-e", fmt.Sprintf("P_EVENTS_COUNT=%s", events_count),
598-
"./scripts/load_historical_batch_events.js",
599-
"--vus=", vus,
600-
"--duration=", duration)
601-
602-
cmd.Run()
603-
op, err := cmd.Output()
604-
if err != nil {
605-
t.Log(err)
606-
}
607-
t.Log(string(op))
608-
}
609-
610-
DeleteStream(t, NewGlob.QueryClient, historicalStream)
611-
}
612-
}
565+
// func TestLoadHistoricalStreamBatchWithK6(t *testing.T) {
566+
// if NewGlob.Mode == "load" {
567+
// historicalStream := NewGlob.Stream + "historical"
568+
// timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
569+
// CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
570+
// if NewGlob.IngestorUrl.String() == "" {
571+
// cmd := exec.Command("k6",
572+
// "run",
573+
// "-e", fmt.Sprintf("P_URL=%s", NewGlob.QueryUrl.String()),
574+
// "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.QueryUsername),
575+
// "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.QueryPassword),
576+
// "-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
577+
// "-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
578+
// "-e", fmt.Sprintf("P_EVENTS_COUNT=%s", events_count),
579+
// "./scripts/load_historical_batch_events.js",
580+
// "--vus=", vus,
581+
// "--duration=", duration)
582+
583+
// cmd.Run()
584+
// op, err := cmd.Output()
585+
// if err != nil {
586+
// t.Log(err)
587+
// }
588+
// t.Log(string(op))
589+
// } else {
590+
// cmd := exec.Command("k6",
591+
// "run",
592+
// "-e", fmt.Sprintf("P_URL=%s", NewGlob.IngestorUrl.String()),
593+
// "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.IngestorUsername),
594+
// "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.IngestorPassword),
595+
// "-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
596+
// "-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
597+
// "-e", fmt.Sprintf("P_EVENTS_COUNT=%s", events_count),
598+
// "./scripts/load_historical_batch_events.js",
599+
// "--vus=", vus,
600+
// "--duration=", duration)
601+
602+
// cmd.Run()
603+
// op, err := cmd.Output()
604+
// if err != nil {
605+
// t.Log(err)
606+
// }
607+
// t.Log(string(op))
608+
// }
609+
610+
// DeleteStream(t, NewGlob.QueryClient, historicalStream)
611+
// }
612+
// }
613613

614614
func TestLoadStreamBatchWithCustomPartitionWithK6(t *testing.T) {
615615
customPartitionStream := NewGlob.Stream + "custompartition"
@@ -702,52 +702,52 @@ func TestLoadStreamNoBatchWithK6(t *testing.T) {
702702
}
703703
}
704704

705-
func TestLoadHistoricalStreamNoBatchWithK6(t *testing.T) {
706-
if NewGlob.Mode == "load" {
707-
historicalStream := NewGlob.Stream + "historical"
708-
timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
709-
CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
710-
if NewGlob.IngestorUrl.String() == "" {
711-
cmd := exec.Command("k6",
712-
"run",
713-
"-e", fmt.Sprintf("P_URL=%s", NewGlob.QueryUrl.String()),
714-
"-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.QueryUsername),
715-
"-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.QueryPassword),
716-
"-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
717-
"-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
718-
"./scripts/load_single_events.js",
719-
"--vus=", vus,
720-
"--duration=", duration)
721-
722-
cmd.Run()
723-
op, err := cmd.Output()
724-
if err != nil {
725-
t.Log(err)
726-
}
727-
t.Log(string(op))
728-
} else {
729-
cmd := exec.Command("k6",
730-
"run",
731-
"-e", fmt.Sprintf("P_URL=%s", NewGlob.IngestorUrl.String()),
732-
"-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.IngestorUsername),
733-
"-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.IngestorPassword),
734-
"-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
735-
"-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
736-
"./scripts/load_single_events.js",
737-
"--vus=", vus,
738-
"--duration=", duration)
739-
740-
cmd.Run()
741-
op, err := cmd.Output()
742-
if err != nil {
743-
t.Log(err)
744-
}
745-
t.Log(string(op))
746-
}
747-
748-
DeleteStream(t, NewGlob.QueryClient, historicalStream)
749-
}
750-
}
705+
// func TestLoadHistoricalStreamNoBatchWithK6(t *testing.T) {
706+
// if NewGlob.Mode == "load" {
707+
// historicalStream := NewGlob.Stream + "historical"
708+
// timeHeader := map[string]string{"X-P-Time-Partition": "source_time"}
709+
// CreateStreamWithHeader(t, NewGlob.QueryClient, historicalStream, timeHeader)
710+
// if NewGlob.IngestorUrl.String() == "" {
711+
// cmd := exec.Command("k6",
712+
// "run",
713+
// "-e", fmt.Sprintf("P_URL=%s", NewGlob.QueryUrl.String()),
714+
// "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.QueryUsername),
715+
// "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.QueryPassword),
716+
// "-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
717+
// "-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
718+
// "./scripts/load_single_events.js",
719+
// "--vus=", vus,
720+
// "--duration=", duration)
721+
722+
// cmd.Run()
723+
// op, err := cmd.Output()
724+
// if err != nil {
725+
// t.Log(err)
726+
// }
727+
// t.Log(string(op))
728+
// } else {
729+
// cmd := exec.Command("k6",
730+
// "run",
731+
// "-e", fmt.Sprintf("P_URL=%s", NewGlob.IngestorUrl.String()),
732+
// "-e", fmt.Sprintf("P_USERNAME=%s", NewGlob.IngestorUsername),
733+
// "-e", fmt.Sprintf("P_PASSWORD=%s", NewGlob.IngestorPassword),
734+
// "-e", fmt.Sprintf("P_STREAM=%s", historicalStream),
735+
// "-e", fmt.Sprintf("P_SCHEMA_COUNT=%s", schema_count),
736+
// "./scripts/load_single_events.js",
737+
// "--vus=", vus,
738+
// "--duration=", duration)
739+
740+
// cmd.Run()
741+
// op, err := cmd.Output()
742+
// if err != nil {
743+
// t.Log(err)
744+
// }
745+
// t.Log(string(op))
746+
// }
747+
748+
// DeleteStream(t, NewGlob.QueryClient, historicalStream)
749+
// }
750+
// }
751751

752752
func TestLoadStreamNoBatchWithCustomPartitionWithK6(t *testing.T) {
753753
customPartitionStream := NewGlob.Stream + "custompartition"

0 commit comments

Comments
 (0)