File tree Expand file tree Collapse file tree 1 file changed +6
-8
lines changed Expand file tree Collapse file tree 1 file changed +6
-8
lines changed Original file line number Diff line number Diff line change @@ -62,14 +62,6 @@ def start_finjector(self):
62
62
self .finjector_thread .daemon = True
63
63
self .finjector_thread .start ()
64
64
65
- def disable_failures (self ):
66
- self .enable_failures = False
67
- self .finjector_thread .join ()
68
-
69
- def enable_failures (self ):
70
- self .enable_failures = True
71
- self .start_finjector ()
72
-
73
65
def random_failure_spec (self ):
74
66
f_type = random .choice (self .allowed_failures )
75
67
length = self .failure_length_provider (f_type )
@@ -97,3 +89,9 @@ def _failure_injector_loop(self):
97
89
self .redpanda .logger .info (
98
90
f"waiting { delay } seconds before next failure" )
99
91
time .sleep (delay )
92
+
93
+ def teardown (self ):
94
+ self .enable_failures = False
95
+ if self .finjector_thread :
96
+ self .finjector_thread .join ()
97
+ FailureInjector (self .redpanda )._heal_all ()
You can’t perform that action at this time.
0 commit comments