Skip to content

Commit

Permalink
refactor: continuously retrieve messages from DAQ job threads
Browse files Browse the repository at this point in the history
  • Loading branch information
furkan-bilgin committed Oct 12, 2024
1 parent bca6456 commit 05fe0cc
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions src/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,10 @@ def loop():
daq_messages = []
for thread in daq_job_threads:
try:
daq_messages.append(
thread.daq_job.message_out.get(timeout=DAQ_JOB_QUEUE_ACTION_TIMEOUT)
)
while True:
daq_messages.append(
thread.daq_job.message_out.get(timeout=DAQ_JOB_QUEUE_ACTION_TIMEOUT)
)
except Empty:
pass

Expand Down

0 comments on commit 05fe0cc

Please sign in to comment.