@@ -520,7 +520,7 @@ def test_carbon_tracker_offline_context_manager(
520520 self .assertEqual ("United States" , emissions_df ["country_name" ].values [0 ])
521521 self .assertEqual ("USA" , emissions_df ["country_iso_code" ].values [0 ])
522522 self .assertIsInstance (tracker .final_emissions , float )
523-
523+
524524 @mock .patch ("codecarbon.emissions_tracker.logger" )
525525 def test_scheduler_warning_suppressed_when_stopped (
526526 self ,
@@ -538,24 +538,31 @@ def test_scheduler_warning_suppressed_when_stopped(
538538 ) as tracker :
539539 # Stop the scheduler to simulate task mode or manual stopping
540540 tracker ._scheduler .stop ()
541-
541+
542542 # Artificially set last measured time to simulate long delay
543543 import time
544+
544545 tracker ._last_measured_time = time .perf_counter () - 10 # 10 seconds ago
545-
546+
546547 # Reset mock to clear any previous warning calls
547548 mock_logger .warning .reset_mock ()
548-
549+
549550 # Call _measure_power_and_energy directly - this would normally trigger warning
550551 tracker ._measure_power_and_energy ()
551-
552+
552553 # Verify that if warning was called, it wasn't the scheduler warning
553554 if mock_logger .warning .called :
554555 for call in mock_logger .warning .call_args_list :
555556 args , kwargs = call
556- if args and "Background scheduler didn't run for a long period" in str (args [0 ]):
557- self .fail ("Scheduler warning was called when it should have been suppressed" )
558-
557+ if (
558+ args
559+ and "Background scheduler didn't run for a long period"
560+ in str (args [0 ])
561+ ):
562+ self .fail (
563+ "Scheduler warning was called when it should have been suppressed"
564+ )
565+
559566 @mock .patch ("codecarbon.emissions_tracker.logger" )
560567 def test_scheduler_warning_shown_when_running (
561568 self ,
@@ -573,24 +580,31 @@ def test_scheduler_warning_shown_when_running(
573580 ) as tracker :
574581 # Ensure scheduler is running (default state)
575582 self .assertFalse (tracker ._scheduler ._stopped )
576-
583+
577584 # Artificially set last measured time to simulate long delay
578585 import time
586+
579587 tracker ._last_measured_time = time .perf_counter () - 10 # 10 seconds ago
580-
588+
581589 # Reset mock to clear any previous warning calls
582590 mock_logger .warning .reset_mock ()
583-
591+
584592 # Call _measure_power_and_energy directly - this should trigger warning
585593 tracker ._measure_power_and_energy ()
586-
594+
587595 # Verify warning was logged since scheduler should be running
588596 scheduler_warning_found = False
589597 if mock_logger .warning .called :
590598 for call in mock_logger .warning .call_args_list :
591599 args , kwargs = call
592- if args and "Background scheduler didn't run for a long period" in str (args [0 ]):
600+ if (
601+ args
602+ and "Background scheduler didn't run for a long period"
603+ in str (args [0 ])
604+ ):
593605 scheduler_warning_found = True
594606 break
595-
596- self .assertTrue (scheduler_warning_found , "Expected scheduler warning was not found" )
607+
608+ self .assertTrue (
609+ scheduler_warning_found , "Expected scheduler warning was not found"
610+ )
0 commit comments