diff --git a/src/libertem_live/detectors/asi_tpx3/acquisition.py b/src/libertem_live/detectors/asi_tpx3/acquisition.py
index 92b6ca2e..55b995e9 100644
--- a/src/libertem_live/detectors/asi_tpx3/acquisition.py
+++ b/src/libertem_live/detectors/asi_tpx3/acquisition.py
@@ -113,7 +113,7 @@ def handle_task(self, task: TaskProtocol, queue: WorkerQueue):
                         })
                         raise JobCancelledError("premature end of frame iterator")
                     break
-                assert len(chunk_stack) <= current_stack_size,\
+                assert len(chunk_stack) <= current_stack_size, \
                     f"{len(chunk_stack)} <= {current_stack_size}"
                 t1 = time.perf_counter()
                 recv_time += t1 - t0
diff --git a/src/libertem_live/detectors/dectris/acquisition.py b/src/libertem_live/detectors/dectris/acquisition.py
index d92af628..885c8e1f 100644
--- a/src/libertem_live/detectors/dectris/acquisition.py
+++ b/src/libertem_live/detectors/dectris/acquisition.py
@@ -147,7 +147,7 @@ def handle_task(self, task: TaskProtocol, queue: WorkerQueue):
                             "type": "END_PARTITION",
                         })
                         raise JobCancelledError("premature end of frame iterator")
-                assert len(frame_stack) <= current_chunk_size,\
+                assert len(frame_stack) <= current_chunk_size, \
                     f"{len(frame_stack)} <= {current_chunk_size}"
                 t1 = time.perf_counter()
                 recv_time += t1 - t0