@@ -981,22 +981,19 @@ def test_parallel_emits_events(self) -> None:
981981
982982 # Should have VALIDATION_STARTED
983983 started_events = [
984- e for e in observer .events
985- if e .event_type == ValidationEventType .VALIDATION_STARTED
984+ e for e in observer .events if e .event_type == ValidationEventType .VALIDATION_STARTED
986985 ]
987986 assert len (started_events ) == 1
988987
989988 # Should have VALIDATION_COMPLETED
990989 completed_events = [
991- e for e in observer .events
992- if e .event_type == ValidationEventType .VALIDATION_COMPLETED
990+ e for e in observer .events if e .event_type == ValidationEventType .VALIDATION_COMPLETED
993991 ]
994992 assert len (completed_events ) == 1
995993
996994 # Should have ROW_PROCESSED for each row
997995 row_events = [
998- e for e in observer .events
999- if e .event_type == ValidationEventType .ROW_PROCESSED
996+ e for e in observer .events if e .event_type == ValidationEventType .ROW_PROCESSED
1000997 ]
1001998 assert len (row_events ) == 10
1002999
@@ -1010,8 +1007,7 @@ def test_parallel_started_event_includes_workers(self) -> None:
10101007 list (runner .run (workers = 4 , chunk_size = 5 ))
10111008
10121009 started_events = [
1013- e for e in observer .events
1014- if e .event_type == ValidationEventType .VALIDATION_STARTED
1010+ e for e in observer .events if e .event_type == ValidationEventType .VALIDATION_STARTED
10151011 ]
10161012 assert len (started_events ) == 1
10171013 assert started_events [0 ].data .get ("workers" ) == 4
@@ -1062,8 +1058,7 @@ def test_parallel_uses_sequential_for_single_worker(self) -> None:
10621058
10631059 # In sequential mode, no worker info in started event
10641060 started_events = [
1065- e for e in observer .events
1066- if e .event_type == ValidationEventType .VALIDATION_STARTED
1061+ e for e in observer .events if e .event_type == ValidationEventType .VALIDATION_STARTED
10671062 ]
10681063 assert "workers" not in started_events [0 ].data
10691064
@@ -1236,14 +1231,18 @@ def test_top_errors_counts_match(self, errors: list[tuple[str, str]]) -> None:
12361231 assert total_from_top == len (errors )
12371232
12381233 @given (
1239- stats1_data = st .fixed_dictionaries ({
1240- "total" : st .integers (min_value = 0 , max_value = 1000 ),
1241- "valid" : st .integers (min_value = 0 , max_value = 1000 ),
1242- }),
1243- stats2_data = st .fixed_dictionaries ({
1244- "total" : st .integers (min_value = 0 , max_value = 1000 ),
1245- "valid" : st .integers (min_value = 0 , max_value = 1000 ),
1246- }),
1234+ stats1_data = st .fixed_dictionaries (
1235+ {
1236+ "total" : st .integers (min_value = 0 , max_value = 1000 ),
1237+ "valid" : st .integers (min_value = 0 , max_value = 1000 ),
1238+ }
1239+ ),
1240+ stats2_data = st .fixed_dictionaries (
1241+ {
1242+ "total" : st .integers (min_value = 0 , max_value = 1000 ),
1243+ "valid" : st .integers (min_value = 0 , max_value = 1000 ),
1244+ }
1245+ ),
12471246 )
12481247 @settings (max_examples = 50 )
12491248 def test_merge_is_additive (
0 commit comments