Flaking
This commit is contained in:
+19
-39
@@ -114,28 +114,21 @@ class AerotechAbrMixin(CustomPrepare):
|
||||
scanname = self.parent.scaninfo.scan_msg.info["scan_name"]
|
||||
|
||||
if scanname in ("standardscan"):
|
||||
scan_start = scanargs["start"]
|
||||
scan_range = scanargs["range"]
|
||||
scan_move_time = scanargs["move_time"]
|
||||
scan_ready_rate = scanargs.get("ready_rate", 500)
|
||||
d["scan_command"] = AbrCmd.MEASURE_STANDARD
|
||||
d["var_1"] = scan_start
|
||||
d["var_2"] = scan_range
|
||||
d["var_3"] = scan_move_time
|
||||
d["var_4"] = scan_ready_rate
|
||||
d["var_1"] = scanargs["start"]
|
||||
d["var_2"] = scanargs["range"]
|
||||
d["var_3"] = scanargs["move_time"]
|
||||
d["var_4"] = scanargs.get("ready_rate", 500)
|
||||
d["var_5"] = 0
|
||||
d["var_6"] = 0
|
||||
d["var_7"] = 0
|
||||
d["var_8"] = 0
|
||||
d["var_9"] = 0
|
||||
if scanname in ("verticallinescan", "vlinescan"):
|
||||
scan_exp_time = scanargs["exp_time"]
|
||||
scan_range_y = scanargs["range"]
|
||||
scan_steps_y = scanargs["steps"]
|
||||
d["scan_command"] = AbrCmd.VERTICAL_LINE_SCAN
|
||||
d["var_1"] = scan_range_y / scan_steps_y
|
||||
d["var_2"] = scan_steps_y
|
||||
d["var_3"] = scan_exp_time
|
||||
d["var_1"] = scanargs["range"] / scanargs["steps"]
|
||||
d["var_2"] = scanargs["steps"]
|
||||
d["var_3"] = scanargs["exp_time"]
|
||||
d["var_4"] = 0
|
||||
d["var_5"] = 0
|
||||
d["var_6"] = 0
|
||||
@@ -143,37 +136,23 @@ class AerotechAbrMixin(CustomPrepare):
|
||||
d["var_8"] = 0
|
||||
d["var_9"] = 0
|
||||
if scanname in ("screeningscan"):
|
||||
scan_start = scanargs["start"]
|
||||
scan_range = scanargs["range"]
|
||||
scan_stepnum_o = scanargs["steps"]
|
||||
scan_exp_time = scanargs["exp_time"]
|
||||
scan_oscrange = scanargs["oscrange"]
|
||||
scan_delta = scanargs.get("delta", 0.5)
|
||||
scan_stepsize_o = scan_range / scan_stepnum_o
|
||||
d["scan_command"] = AbrCmd.SCREENING
|
||||
d["var_1"] = scan_start
|
||||
d["var_2"] = scan_oscrange
|
||||
d["var_3"] = scan_exp_time
|
||||
d["var_4"] = scan_stepsize_o
|
||||
d["var_5"] = scan_stepnum_o
|
||||
d["var_6"] = scan_delta
|
||||
d["var_1"] = scanargs["start"]
|
||||
d["var_2"] = scanargs["oscrange"]
|
||||
d["var_3"] = scanargs["exp_time"]
|
||||
d["var_4"] = scanargs["range"] / scanargs["steps"]
|
||||
d["var_5"] = scanargs["steps"]
|
||||
d["var_6"] = scanargs.get("delta", 0.5)
|
||||
d["var_7"] = 0
|
||||
d["var_8"] = 0
|
||||
d["var_9"] = 0
|
||||
if scanname in ("rasterscan", "rastersimplescan"):
|
||||
scan_exp_time = scanargs["exp_time"]
|
||||
scan_range_x = scanargs["range_x"]
|
||||
scan_range_y = scanargs["range_y"]
|
||||
scan_stepnum_x = scanargs["steps_x"]
|
||||
scan_stepnum_y = scanargs["steps_y"]
|
||||
scan_stepsize_x = scan_range_x / scan_stepnum_x
|
||||
scan_stepsize_y = scan_range_y / scan_stepnum_y
|
||||
d["scan_command"] = AbrCmd.RASTER_SCAN_SIMPLE
|
||||
d["var_1"] = scan_exp_time
|
||||
d["var_2"] = scan_stepsize_x
|
||||
d["var_3"] = scan_stepsize_y
|
||||
d["var_4"] = scan_stepnum_x
|
||||
d["var_5"] = scan_stepnum_y
|
||||
d["var_1"] = scanargs["exp_time"]
|
||||
d["var_2"] = scanargs["range_x"] / scanargs["steps_x"]
|
||||
d["var_3"] = scanargs["range_y"] / scanargs["steps_y"]
|
||||
d["var_4"] = scanargs["steps_x"]
|
||||
d["var_5"] = scanargs["steps_y"]
|
||||
d["var_6"] = 0
|
||||
d["var_7"] = 0
|
||||
d["var_8"] = 0
|
||||
@@ -412,6 +391,7 @@ class AerotechAbrStage(BECDeviceBase):
|
||||
|
||||
@property
|
||||
def axis_mode(self):
|
||||
"""Read axis mode"""
|
||||
return self.axisAxesMode.get()
|
||||
|
||||
# @property
|
||||
|
||||
@@ -89,6 +89,7 @@ class A3200Axis(PVPositioner):
|
||||
vmax = Component(Signal, kind=Kind.config)
|
||||
offset = Component(EpicsSignal, "-OFF", put_complete=True, kind=Kind.config)
|
||||
|
||||
#pylint: disable=too-many-arguments
|
||||
def __init__(
|
||||
self,
|
||||
prefix="",
|
||||
|
||||
@@ -41,6 +41,7 @@ class SmarGonSignal(Signal):
|
||||
#pylint: disable=protected-access
|
||||
r = self.parent._go_n_put(f"{self.write_addr}?{self.addr.upper()}={value}")
|
||||
|
||||
#pylint: disable=attribute-defined-outside-init
|
||||
old_value = self._readback
|
||||
self._timestamp = timestamp
|
||||
self._readback = r[self.addr.upper()]
|
||||
@@ -66,15 +67,14 @@ class SmarGonSignal(Signal):
|
||||
if value > hil:
|
||||
raise ValueError(f"Target {value} outside of limits {self.limits}")
|
||||
|
||||
def get(self, *args, **kwargs):
|
||||
def get(self, **kwargs):
|
||||
#pylint: disable=protected-access
|
||||
r = self.parent._go_n_get(self.write_addr)
|
||||
# print(r)
|
||||
if isinstance(r, dict):
|
||||
self._value = r[self.addr.upper()]
|
||||
else:
|
||||
self._value = r
|
||||
return super().get(*args, **kwargs)
|
||||
|
||||
#pylint: disable=attribute-defined-outside-init
|
||||
self._value = r[self.addr.upper()] if isinstance(r, dict) else r
|
||||
return super().get(**kwargs)
|
||||
|
||||
|
||||
class SmarGonSignalRO(Signal):
|
||||
@@ -93,7 +93,7 @@ class SmarGonSignalRO(Signal):
|
||||
self._mon = Thread(target=self.poll, daemon=True)
|
||||
self._mon.start()
|
||||
|
||||
def get(self, *args, **kwargs):
|
||||
def get(self, **kwargs):
|
||||
#pylint: disable=protected-access
|
||||
r = self.parent._go_n_get(self.read_addr)
|
||||
|
||||
@@ -107,7 +107,7 @@ class SmarGonSignalRO(Signal):
|
||||
""" Fooo"""
|
||||
time.sleep(2)
|
||||
while True:
|
||||
time.sleep(0.2)
|
||||
time.sleep(0.25)
|
||||
try:
|
||||
self.get()
|
||||
except requests.ConnectTimeout as ex:
|
||||
@@ -135,6 +135,7 @@ class SmarGonAxis(PVPositioner):
|
||||
moving = 1
|
||||
_tol = 0.001
|
||||
|
||||
#pylint: disable=too-many-arguments
|
||||
def __init__(
|
||||
self,
|
||||
prefix="SCS",
|
||||
|
||||
@@ -51,6 +51,7 @@ class StdDaqPreviewMixin(CustomDetectorMixin):
|
||||
self._mon.join(timeout=1)
|
||||
# So also disconnect the socket
|
||||
try:
|
||||
#pylint: disable=protected-access
|
||||
self.parent._socket.disconnect(self.parent.url.get())
|
||||
except zmq.error.ZMQError:
|
||||
# Might be already closed
|
||||
@@ -72,6 +73,7 @@ class StdDaqPreviewMixin(CustomDetectorMixin):
|
||||
break
|
||||
|
||||
# pylint: disable=no-member
|
||||
#pylint: disable=protected-access
|
||||
r = self.parent._socket.recv_multipart(flags=zmq.NOBLOCK)
|
||||
|
||||
# Length and throtling checks
|
||||
@@ -103,6 +105,7 @@ class StdDaqPreviewMixin(CustomDetectorMixin):
|
||||
# self.parent.array_data.put(data, force=True)
|
||||
self.parent.shaped_image.put(image, force=True)
|
||||
|
||||
#pylint: disable=protected-access
|
||||
self.parent._last_image = image
|
||||
self.parent._run_subs(sub_type=self.parent.SUB_MONITOR, value=image)
|
||||
t_last = t_curr
|
||||
|
||||
Reference in New Issue
Block a user