From 4ebcbb3ee3aef91d869d30055e77169579bfca33 Mon Sep 17 00:00:00 2001
From: Sergey Yakubov <sergey.yakubov@desy.de>
Date: Wed, 28 Oct 2020 09:16:55 +0100
Subject: [PATCH] get_substream_list - return all substreams by default in
python
---
consumer/api/cpp/include/consumer/data_broker.h | 2 +-
consumer/api/python/asapo_consumer.pyx.in | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/consumer/api/cpp/include/consumer/data_broker.h b/consumer/api/cpp/include/consumer/data_broker.h
index 664554b0e..e76881e85 100644
--- a/consumer/api/cpp/include/consumer/data_broker.h
+++ b/consumer/api/cpp/include/consumer/data_broker.h
@@ -74,7 +74,7 @@ class DataBroker {
*/
virtual NetworkConnectionType CurrentConnectionType() const = 0;
- //! Set list of substreams
+ //! Get list of substreams, set from to "" to get all substreams
virtual StreamInfos GetSubstreamList(std::string from, Error* err) = 0;
//! Get current number of datasets
diff --git a/consumer/api/python/asapo_consumer.pyx.in b/consumer/api/python/asapo_consumer.pyx.in
index 179816357..0022eef0a 100644
--- a/consumer/api/python/asapo_consumer.pyx.in
+++ b/consumer/api/python/asapo_consumer.pyx.in
@@ -203,7 +203,7 @@ cdef class PyDataBroker:
if err:
throw_exception(err)
return _str(group_id)
- def get_substream_list(self,from_substream):
+ def get_substream_list(self, from_substream = ""):
cdef Error err
cdef vector[StreamInfo] substreams
cdef string b_from_substream = _bytes(from_substream)
--
GitLab