bec/ophyd_devices
0
0
Fork 0
mirror of https://github.com/bec-project/ophyd_devices.git synced 2025-07-12 03:31:54 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor: add _send_requests_delete

Browse Source
This commit is contained in:
appel_c
2023-11-06 14:55:42 +01:00
parent d2cd6a442b
commit 4ce26b5dd5
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
ophyd_devices/epics/devices/pilatus_csaxs.py
View File

@ -332,11 +332,32 @@ class PilatuscSAXS(DetectorBase):
except Exception as exc:
logger.info(f"Pilatus2 wait threw Exception: {exc}")
def _send_requests_put(self, url: str, data_msg: dict = None, headers: dict = None) -> None:
...
def _send_requests_delete(self, url: str, headers: dict = None) -> None:
"""
Send a delete request to the given url
Args:
url (str): url to send the request to
headers (dict): headers to be sent with the request (optional)
"""
try:
res = requests.delete(url=url, headers=headers)
if not res.ok:
res.raise_for_status()
except Exception as exc:
logger.info(f"Pilatus2 delete threw Exception: {exc}")
def _close_file_writer(self) -> None:
"""Close the file writer for pilatus_2
a zmq service is running on xbl-daq-34 that is waiting
for a zmq message to stop the writer for the pilatus_2 x12sa-pd-2
"""
url = "http://x12sa-pd-2:8080/stream/pilatus_2"
self._send_requests_delete(url=url)
try:
res = requests.delete(url="http://x12sa-pd-2:8080/stream/pilatus_2")
if not res.ok: