From 2e9603809ab7192c16c00cb4f7b065b9707eccc2 Mon Sep 17 00:00:00 2001
From: karnem <mikhail.karnevskiy@desy.de>
Date: Thu, 7 Sep 2023 11:59:23 +0200
Subject: [PATCH] Fix swap between get_next and get_next_available
---
consumer/api/python/asapo_consumer.pyx.in | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/consumer/api/python/asapo_consumer.pyx.in b/consumer/api/python/asapo_consumer.pyx.in
index 6c5ceb367..5c8b8b4a0 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)
--
GitLab