@@ -1151,7 +1151,7 @@ def test_flush_with_none_channel_after_connection_check(self, mock_exists: Mock,
11511151class TestStateMarkerIntegration :
11521152 """Test StateMarker integration in ConcurrentExtractor."""
11531153
1154- def test_state_marker_file_start_tracking (self , _temp_dir : Path ) -> None :
1154+ def test_state_marker_file_start_tracking (self ) -> None :
11551155 """Test that state marker tracks file processing start."""
11561156 from common import StateMarker
11571157
@@ -1164,7 +1164,7 @@ def test_state_marker_file_start_tracking(self, _temp_dir: Path) -> None:
11641164 assert file_progress is not None
11651165 assert file_progress .status == "in_progress"
11661166
1167- def test_state_marker_file_completion_tracking (self , _temp_dir : Path ) -> None :
1167+ def test_state_marker_file_completion_tracking (self ) -> None :
11681168 """Test that state marker tracks file processing completion."""
11691169 from common import StateMarker
11701170
@@ -1178,7 +1178,7 @@ def test_state_marker_file_completion_tracking(self, _temp_dir: Path) -> None:
11781178 assert file_progress .status == "completed"
11791179 assert file_progress .records_extracted == 1000
11801180
1181- def test_state_marker_periodic_progress_update (self , _temp_dir : Path ) -> None :
1181+ def test_state_marker_periodic_progress_update (self ) -> None :
11821182 """Test that state marker updates progress periodically."""
11831183 from common import StateMarker
11841184
0 commit comments