@@ -61,7 +61,7 @@ def __init__(
6161 ) -> None :
6262 self ._drv = odin_driver
6363 self ._path_provider = path_provider
64- self ._detector_bit_depth = Reference ( detector_bit_depth )
64+ self ._detector_bit_depth = detector_bit_depth
6565 super ().__init__ ()
6666
6767 async def open (self , name : str , exposures_per_event : int = 1 ) -> dict [str , DataKey ]:
@@ -70,7 +70,7 @@ async def open(self, name: str, exposures_per_event: int = 1) -> dict[str, DataK
7070
7171 await asyncio .gather (
7272 self ._drv .fp .data_datatype .set (
73- f"uint{ await self ._detector_bit_depth () .get_value ()} "
73+ f"uint{ await self ._detector_bit_depth .get_value ()} "
7474 ),
7575 self ._drv .fp .data_compression .set ("BSLZ4" ),
7676 self ._drv .fp .frames .set (exposures_per_event ),
@@ -81,7 +81,7 @@ async def open(self, name: str, exposures_per_event: int = 1) -> dict[str, DataK
8181 self ._drv .mw .acquisition_id .set (info .filename ),
8282 )
8383
84- await self ._drv .fp .start_writing .trigger (wait = True )
84+ await self ._drv .fp .start_writing .trigger ()
8585
8686 await asyncio .gather (
8787 wait_for_value (self ._drv .fp .writing , True , timeout = DEFAULT_TIMEOUT ),
@@ -124,6 +124,6 @@ def collect_stream_docs(
124124
125125 async def close (self ) -> None :
126126 await asyncio .gather (
127- self ._drv .fp .stop_writing .trigger (wait = True ),
128- self ._drv .mw .stop .trigger (wait = True ),
127+ self ._drv .fp .stop_writing .trigger (),
128+ self ._drv .mw .stop .trigger (),
129129 )
0 commit comments