@@ -16,27 +16,27 @@ def teardown_method(self):
16
16
@classmethod
17
17
def teardown_class (cls ):
18
18
delete_pcf_org ()
19
- #
20
- # @pytest.mark.Perf_Binary
21
- # @pytest.mark.parametrize("config_input", [
22
- # {'HEC_WORKERS': 1, 'HEC_BATCH_SIZE': 100, 'EXTRA_FIELDS': 'test_tag:01worker100batch'},
23
- # {'HEC_WORKERS': 2, 'HEC_BATCH_SIZE': 100, 'EXTRA_FIELDS': 'test_tag:02worker100batch'},
24
- # {'HEC_WORKERS': 4, 'HEC_BATCH_SIZE': 100, 'EXTRA_FIELDS': 'test_tag:04worker100batch'},
25
- # {'HEC_WORKERS': 8, 'HEC_BATCH_SIZE': 100, 'EXTRA_FIELDS': 'test_tag:08worker100batch'},
26
- # {'HEC_WORKERS': 16, 'HEC_BATCH_SIZE': 100, 'EXTRA_FIELDS': 'test_tag:16worker100batch'},
27
- # {'HEC_WORKERS': 1, 'HEC_BATCH_SIZE': 1000, 'EXTRA_FIELDS': 'test_tag:01worker1000batch'},
28
- # {'HEC_WORKERS': 2, 'HEC_BATCH_SIZE': 1000, 'EXTRA_FIELDS': 'test_tag:02worker1000batch'},
29
- # {'HEC_WORKERS': 4, 'HEC_BATCH_SIZE': 1000, 'EXTRA_FIELDS': 'test_tag:04worker1000batch'},
30
- # {'HEC_WORKERS': 8, 'HEC_BATCH_SIZE': 1000, 'EXTRA_FIELDS': 'test_tag:08worker1000batch'},
31
- # {'HEC_WORKERS': 16, 'HEC_BATCH_SIZE': 1000, 'EXTRA_FIELDS': 'test_tag:16worker1000batch'},
32
- # ])
33
- # def test_nozzle_performance_with_local_binary(self, config_input, test_env):
34
- # self.data_gen_name = config_input['EXTRA_FIELDS'].split(':')[1]
35
- # update_data_gen_manifest(input_dict={'name': self.data_gen_name,
36
- # 'env': {'GOPACKAGENAME': 'main', 'EPS': 500, 'TOTAL_EVENTS': 0}})
37
- # deploy_date_gen_to_pcf()
38
- # update_environment_variables(input_dict=config_input)
39
- # start_local_nozzle_binary(time_interval=1200)
19
+
20
+ @pytest .mark .Perf_Binary
21
+ @pytest .mark .parametrize ("config_input" , [
22
+ {'HEC_WORKERS' : 1 , 'HEC_BATCH_SIZE' : 100 , 'EXTRA_FIELDS' : 'test_tag:01worker100batch' },
23
+ {'HEC_WORKERS' : 2 , 'HEC_BATCH_SIZE' : 100 , 'EXTRA_FIELDS' : 'test_tag:02worker100batch' },
24
+ {'HEC_WORKERS' : 4 , 'HEC_BATCH_SIZE' : 100 , 'EXTRA_FIELDS' : 'test_tag:04worker100batch' },
25
+ {'HEC_WORKERS' : 8 , 'HEC_BATCH_SIZE' : 100 , 'EXTRA_FIELDS' : 'test_tag:08worker100batch' },
26
+ {'HEC_WORKERS' : 16 , 'HEC_BATCH_SIZE' : 100 , 'EXTRA_FIELDS' : 'test_tag:16worker100batch' },
27
+ {'HEC_WORKERS' : 1 , 'HEC_BATCH_SIZE' : 1000 , 'EXTRA_FIELDS' : 'test_tag:01worker1000batch' },
28
+ {'HEC_WORKERS' : 2 , 'HEC_BATCH_SIZE' : 1000 , 'EXTRA_FIELDS' : 'test_tag:02worker1000batch' },
29
+ {'HEC_WORKERS' : 4 , 'HEC_BATCH_SIZE' : 1000 , 'EXTRA_FIELDS' : 'test_tag:04worker1000batch' },
30
+ {'HEC_WORKERS' : 8 , 'HEC_BATCH_SIZE' : 1000 , 'EXTRA_FIELDS' : 'test_tag:08worker1000batch' },
31
+ {'HEC_WORKERS' : 16 , 'HEC_BATCH_SIZE' : 1000 , 'EXTRA_FIELDS' : 'test_tag:16worker1000batch' },
32
+ ])
33
+ def test_nozzle_performance_with_local_binary (self , config_input , test_env ):
34
+ self .data_gen_name = config_input ['EXTRA_FIELDS' ].split (':' )[1 ]
35
+ update_data_gen_manifest (input_dict = {'name' : self .data_gen_name ,
36
+ 'env' : {'GOPACKAGENAME' : 'main' , 'EPS' : 500 , 'TOTAL_EVENTS' : 0 }})
37
+ deploy_date_gen_to_pcf ()
38
+ update_environment_variables (input_dict = config_input )
39
+ start_local_nozzle_binary (time_interval = 1200 )
40
40
41
41
@pytest .mark .Perf_Romote
42
42
@pytest .mark .parametrize ("config_input" , [
0 commit comments