w
This commit is contained in:
@@ -536,13 +536,13 @@ if __name__ == "__main__": # pragma: no cover
|
||||
logger.warning("Breaking loop manually after 20 seconds of waiting.")
|
||||
status.set_exception(f"Failed to complete trigger after 20 seconds")
|
||||
break
|
||||
n_messages = len(timepix._msg_dump)
|
||||
logger.warning(f"Messages in Buffer is {n_messages}")
|
||||
if n_messages > 0:
|
||||
msg = timepix._msg_dump[-1]
|
||||
logger.warning(
|
||||
f"Last message had N start_frame : {msg.get('start_frame')}, N data_frames: {len(msg.get('data_frame'))}, N end_frame : {msg.get('end_frame')}"
|
||||
)
|
||||
# n_messages = len(timepix._msg_dump)
|
||||
# logger.warning(f"Messages in Buffer is {n_messages}")
|
||||
# if n_messages > 0:
|
||||
# msg = timepix._msg_dump[-1]
|
||||
# logger.warning(
|
||||
# f"Last message had N start_frame : {msg.get('start_frame')}, N data_frames: {len(msg.get('data_frame'))}, N end_frame : {msg.get('end_frame')}"
|
||||
# )
|
||||
status = timepix.complete()
|
||||
print("Waiting for timepix to complete.")
|
||||
status.wait(timeout=10)
|
||||
|
||||
Reference in New Issue
Block a user