diff --git a/consumer/api/python/asapo_consumer.pyx.in b/consumer/api/python/asapo_consumer.pyx.in
index 6c5ceb36766eb20d71f85734b32bfcd0e64b28ce..5c8b8b4a0bdc426936d035630d0945f3c7aa50d1 100644
--- a/consumer/api/python/asapo_consumer.pyx.in
+++ b/consumer/api/python/asapo_consumer.pyx.in
@@ -134,10 +134,10 @@ cdef class PyConsumer:
         cdef np.npy_intp dims[1]
         if op == "next":
             with nogil:
-                err =  self.c_consumer.get().GetNext(b_group_id, &info, p_data, b_stream, False)
+                err =  self.c_consumer.get().GetNext(b_group_id, &info, p_data, b_stream, True)
         elif op == "next_available":
             with nogil:
-                err =  self.c_consumer.get().GetNext(b_group_id, &info, p_data, b_stream, True)
+                err =  self.c_consumer.get().GetNext(b_group_id, &info, p_data, b_stream, False)
         elif op == "last" and group_id == "":
             with nogil:
                 err =  self.c_consumer.get().GetLast(&info, p_data, b_stream)