Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/secop_ophyd/SECoPDevices.py
Original file line number Diff line number Diff line change
Expand Up @@ -1105,7 +1105,7 @@ async def _move(self, new_target):
self._success = True
self._stopped = False

await self.target.set(new_target, wait=False)
await self.target.set(new_target)
self.logger.info(f"Moving {self.name} to {new_target}")

# force reading of status from device
Expand Down
13 changes: 4 additions & 9 deletions src/secop_ophyd/SECoPSignal.py
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ def source(self, name: str, read: bool) -> str:
async def connect(self, timeout: float):
pass

async def put(self, value: Any | None, wait=True):
async def put(self, value: Any | None):
self.reading.set_reading(self.SECoP_type_info.val2secop(value))

if self.callback is not None:
Expand Down Expand Up @@ -174,7 +174,7 @@ def source(self, name: str, read: bool) -> str:
async def connect(self, timeout: float):
pass

async def put(self, value: Any | None, wait=True):
async def put(self, value: Any | None):

if self.argument is None:
argument = None
Expand Down Expand Up @@ -442,7 +442,7 @@ async def _init_property(self):
self.readonly = True
self.datatype = self.SECoP_type_info.np_datatype

async def put(self, value: Any | None, wait=True):
async def put(self, value: Any | None):
"""Put a value to the parameter. Properties are readonly."""

if self.attribute_type == AttributeType.PROPERTY:
Expand All @@ -454,12 +454,7 @@ async def put(self, value: Any | None, wait=True):
# convert to frappy compatible Format
secop_val = self.SECoP_type_info.val2secop(value)

# frappy client has no ability to just send a secop message without
# waiting for a reply
await asyncio.wait_for(
self._secclient.set_parameter(**self.get_param_path(), value=secop_val),
timeout=None,
)
await self._secclient.set_parameter(**self.get_param_path(), value=secop_val)

async def get_datakey(self, source: str) -> DataKey:
"""Metadata like source, dtype, shape, precision, units"""
Expand Down
Loading