File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
src/rockingester_lib/collectors Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -335,15 +335,12 @@ async def scrape_plate_directory_if_complete(
335335 # TODO: Verify that time.time() where rockingester runs matches os.stat() on filesystem from which images are collected.
336336 waited_seconds = time .time () - max_mtime
337337
338- # Sort wells by name so that tests are deterministic.
339- subwell_names .sort ()
340-
341338 # Make an object corresponding to the crystal plate model's type.
342339 crystal_plate_object = CrystalPlateObjects ().build_object (
343340 {"type" : crystal_plate_model .thing_type }
344341 )
345342
346- # Don't handle the plate directory until all images have arrived.
343+ # Don't handle the plate directory until all images have arrived or some maximum wait has exceeded .
347344 if len (subwell_names ) < crystal_plate_object .get_well_count ():
348345 if waited_seconds < max_wait_seconds :
349346 logger .debug (
@@ -361,13 +358,16 @@ async def scrape_plate_directory_if_complete(
361358 f" after waiting { '%0.1f' % waited_seconds } out of { max_wait_seconds } seconds"
362359 )
363360 else :
364- logger .warning (
361+ logger .debug (
365362 f"[PLATEDONE] done waiting since found all { len (subwell_names )} "
366363 f" out of { crystal_plate_object .get_well_count ()} subwell images"
367364 f" in { plate_directory } "
368365 f" after waiting { '%0.1f' % waited_seconds } out of { max_wait_seconds } seconds"
369366 )
370367
368+ # Sort wells by name so that tests are deterministic.
369+ subwell_names .sort ()
370+
371371 crystal_well_models : List [CrystalWellModel ] = []
372372 for subwell_name in subwell_names :
373373 # Make the well model, including image width/height.
You can’t perform that action at this time.
0 commit comments