@@ -367,8 +367,12 @@ def two_datasets(self, tmp_path):
367367 raw_path = str (cfg ["raw_path" ]),
368368 target_path = str (cfg ["gt_path" ]),
369369 classes = cfg ["classes" ],
370- input_arrays = {"raw" : {"shape" : (8 , 8 , 8 ), "scale" : (4.0 , 4.0 , 4.0 )}},
371- target_arrays = {"gt" : {"shape" : (8 , 8 , 8 ), "scale" : (4.0 , 4.0 , 4.0 )}},
370+ input_arrays = {
371+ "raw" : {"shape" : (8 , 8 , 8 ), "scale" : (4.0 , 4.0 , 4.0 )}
372+ },
373+ target_arrays = {
374+ "gt" : {"shape" : (8 , 8 , 8 ), "scale" : (4.0 , 4.0 , 4.0 )}
375+ },
372376 force_has_data = True ,
373377 )
374378 )
@@ -439,7 +443,7 @@ def test_executor_lazy_init(self, tmp_path):
439443 )
440444
441445 assert ds ._executor is None # not yet created
442- _ = ds .executor # trigger lazy init
446+ _ = ds .executor # trigger lazy init
443447 assert os .getpid () in _PROCESS_EXECUTORS
444448
445449 def test_pid_change_triggers_new_executor (self , two_datasets ):
@@ -451,7 +455,7 @@ def test_pid_change_triggers_new_executor(self, two_datasets):
451455
452456 ds0 , _ = two_datasets
453457 original_executor = ds0 .executor # ensure cached
454- fake_pid = os .getpid () + 99999 # a PID that isn't in the dict
458+ fake_pid = os .getpid () + 99999 # a PID that isn't in the dict
455459
456460 with patch ("cellmap_data.dataset.os.getpid" , return_value = fake_pid ):
457461 # Force re-evaluation by clearing the cached pid
0 commit comments