@@ -255,7 +255,6 @@ def test_run_missing_namespace(self):
255255 result = self .plugin .run (
256256 run_uuid = "test-uuid" ,
257257 scenario = scenario_path ,
258- krkn_config = {},
259258 lib_telemetry = mock_telemetry ,
260259 scenario_telemetry = mock_scenario_telemetry ,
261260 )
@@ -279,7 +278,6 @@ def test_run_missing_pvc_and_pod_name(self):
279278 result = self .plugin .run (
280279 run_uuid = "test-uuid" ,
281280 scenario = scenario_path ,
282- krkn_config = {},
283281 lib_telemetry = mock_telemetry ,
284282 scenario_telemetry = mock_scenario_telemetry ,
285283 )
@@ -306,7 +304,6 @@ def test_run_pod_not_found(self):
306304 result = self .plugin .run (
307305 run_uuid = "test-uuid" ,
308306 scenario = scenario_path ,
309- krkn_config = {},
310307 lib_telemetry = mock_telemetry ,
311308 scenario_telemetry = mock_scenario_telemetry ,
312309 )
@@ -340,7 +337,6 @@ def test_run_pvc_not_found_for_pod(self):
340337 result = self .plugin .run (
341338 run_uuid = "test-uuid" ,
342339 scenario = scenario_path ,
343- krkn_config = {},
344340 lib_telemetry = mock_telemetry ,
345341 scenario_telemetry = mock_scenario_telemetry ,
346342 )
@@ -395,7 +391,6 @@ def test_run_invalid_fill_percentage(self):
395391 result = self .plugin .run (
396392 run_uuid = "test-uuid" ,
397393 scenario = scenario_path ,
398- krkn_config = {},
399394 lib_telemetry = mock_telemetry ,
400395 scenario_telemetry = mock_scenario_telemetry ,
401396 )
@@ -404,8 +399,7 @@ def test_run_invalid_fill_percentage(self):
404399 self .assertEqual (result , 1 )
405400
406401 @patch ("krkn.scenario_plugins.pvc.pvc_scenario_plugin.time.sleep" )
407- @patch ("krkn.scenario_plugins.pvc.pvc_scenario_plugin.cerberus.publish_kraken_status" )
408- def test_run_success_with_fallocate (self , mock_publish , mock_sleep ):
402+ def test_run_success_with_fallocate (self , mock_sleep ):
409403 """Test successful run using fallocate"""
410404 with tempfile .TemporaryDirectory () as temp_dir :
411405 scenario_config = {
@@ -460,7 +454,6 @@ def test_run_success_with_fallocate(self, mock_publish, mock_sleep):
460454 result = self .plugin .run (
461455 run_uuid = "test-uuid" ,
462456 scenario = scenario_path ,
463- krkn_config = {},
464457 lib_telemetry = mock_telemetry ,
465458 scenario_telemetry = mock_scenario_telemetry ,
466459 )
@@ -469,8 +462,7 @@ def test_run_success_with_fallocate(self, mock_publish, mock_sleep):
469462 mock_sleep .assert_called_once_with (1 )
470463
471464 @patch ("krkn.scenario_plugins.pvc.pvc_scenario_plugin.time.sleep" )
472- @patch ("krkn.scenario_plugins.pvc.pvc_scenario_plugin.cerberus.publish_kraken_status" )
473- def test_run_success_with_dd (self , mock_publish , mock_sleep ):
465+ def test_run_success_with_dd (self , mock_sleep ):
474466 """Test successful run using dd when fallocate is not available"""
475467 with tempfile .TemporaryDirectory () as temp_dir :
476468 scenario_config = {
@@ -525,7 +517,6 @@ def test_run_success_with_dd(self, mock_publish, mock_sleep):
525517 result = self .plugin .run (
526518 run_uuid = "test-uuid" ,
527519 scenario = scenario_path ,
528- krkn_config = {},
529520 lib_telemetry = mock_telemetry ,
530521 scenario_telemetry = mock_scenario_telemetry ,
531522 )
@@ -582,7 +573,6 @@ def test_run_no_binary_available(self):
582573 result = self .plugin .run (
583574 run_uuid = "test-uuid" ,
584575 scenario = scenario_path ,
585- krkn_config = {},
586576 lib_telemetry = mock_telemetry ,
587577 scenario_telemetry = mock_scenario_telemetry ,
588578 )
@@ -597,7 +587,6 @@ def test_run_file_not_found(self):
597587 result = self .plugin .run (
598588 run_uuid = "test-uuid" ,
599589 scenario = "/non/existent/path.yaml" ,
600- krkn_config = {},
601590 lib_telemetry = mock_telemetry ,
602591 scenario_telemetry = mock_scenario_telemetry ,
603592 )
@@ -659,14 +648,12 @@ def test_run_both_pvc_and_pod_name_provided(self):
659648 mock_scenario_telemetry = MagicMock ()
660649
661650 with patch ("krkn.scenario_plugins.pvc.pvc_scenario_plugin.time.sleep" ):
662- with patch ("krkn.scenario_plugins.pvc.pvc_scenario_plugin.cerberus.publish_kraken_status" ):
663- result = self .plugin .run (
664- run_uuid = "test-uuid" ,
665- scenario = scenario_path ,
666- krkn_config = {},
667- lib_telemetry = mock_telemetry ,
668- scenario_telemetry = mock_scenario_telemetry ,
669- )
651+ result = self .plugin .run (
652+ run_uuid = "test-uuid" ,
653+ scenario = scenario_path ,
654+ lib_telemetry = mock_telemetry ,
655+ scenario_telemetry = mock_scenario_telemetry ,
656+ )
670657
671658 self .assertEqual (result , 0 )
672659 # get_pod_info should be called with "actual-pod-from-pvc", not "ignored-pod"
@@ -707,7 +694,6 @@ def test_run_pvc_name_only_no_pods_associated(self):
707694 result = self .plugin .run (
708695 run_uuid = "test-uuid" ,
709696 scenario = scenario_path ,
710- krkn_config = {},
711697 lib_telemetry = mock_telemetry ,
712698 scenario_telemetry = mock_scenario_telemetry ,
713699 )
@@ -770,7 +756,6 @@ def test_run_file_creation_failed(self):
770756 result = self .plugin .run (
771757 run_uuid = "test-uuid" ,
772758 scenario = scenario_path ,
773- krkn_config = {},
774759 lib_telemetry = mock_telemetry ,
775760 scenario_telemetry = mock_scenario_telemetry ,
776761 )
0 commit comments