File tree Expand file tree Collapse file tree 1 file changed +8
-5
lines changed Expand file tree Collapse file tree 1 file changed +8
-5
lines changed Original file line number Diff line number Diff line change @@ -16,17 +16,19 @@ def measure_memory_usage():
16
16
print (virtual_memory ().used )
17
17
18
18
19
+ def backup_isisicp_config ():
20
+ config_backup = ConfigObj (icp_config_file_path )
21
+ config_backup .filename = icp_config_backup_file_path
22
+ config_backup .write ()
23
+
24
+
19
25
def restore_isisicp_config ():
20
26
config = ConfigObj (icp_config_backup_file_path )
21
27
config .filename = icp_config_file_path
22
28
config .write ()
23
29
24
30
25
31
def turn_on_datastreaming ():
26
- config_backup = ConfigObj (icp_config_file_path )
27
- config_backup .filename = icp_config_backup_file_path
28
- config_backup .write ()
29
-
30
32
config = ConfigObj (icp_config_file_path )
31
33
config ["isisicp.kafkastream" ] = True
32
34
config ["isisicp.kafkastream.topicprefix" ] = "TEST"
@@ -50,6 +52,7 @@ def turn_on_datastreaming():
50
52
51
53
if not args .tear_down :
52
54
measure_memory_usage ()
53
- turn_on_datastreaming ()
55
+ backup_isisicp_config ()
56
+ #turn_on_datastreaming()
54
57
else :
55
58
restore_isisicp_config ()
You can’t perform that action at this time.
0 commit comments