rahix/openflexure-microscope-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Format fixes

Browse source
This commit is contained in:
Richard Bowman 2026-02-10 23:38:29 +00:00 • committed by Julian Stirling
parent d09a5a8ee2
commit 04e7fa30bd
1 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/openflexure_microscope_server/things/stage/sangaboard.py
View file

@ -7,7 +7,7 @@ import time
from collections.abc import Sequence from collections.abc import Sequence
from contextlib import contextmanager from contextlib import contextmanager
from copy import copy from copy import copy
from queue import Queue, Empty from queue import Empty, Queue
from types import TracebackType from types import TracebackType
from typing import Any, Iterator, Literal, Optional, Self from typing import Any, Iterator, Literal, Optional, Self
@ -370,17 +370,20 @@ class SangaboardThing(BaseStage):
try: try:
waitstart = time.time() waitstart = time.time()
command = self._jog_queue.get(timeout=duration) command = self._jog_queue.get(timeout=duration)
self.logger.info(f"Got command {command} after {time.time() - waitstart}") self.logger.info(
f"Got command {command} after {time.time() - waitstart}"
)
except Empty: except Empty:
self.logger.info(f"Timed out waiting for a command, waited {duration}.") self.logger.info(
f"Timed out waiting for a command, waited {duration}."
)
if self._poll_moving(): if self._poll_moving():
# If there's no new command, keep checking for new commands until # If there's no new command, keep checking for new commands until
# we stop. # we stop.
self.logger.info(f"Still moving, will wait for the stage to stop.")
duration = 0.1 duration = 0.1
continue continue
# Once the stage is no longer moving, stop listening for commands. # Once the stage is no longer moving, stop listening for commands.
self.logger.info(f"Stage has stopped, terminating.") self.logger.info("Stage has stopped, terminating jog thread.")
break break
command.received.set() # Acknowledge the command command.received.set() # Acknowledge the command
if previous_command: if previous_command: