This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch chore/introduce-function-definition in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 68d2dbb0457d14f7b3dbdd4d64a5a464d03e87c2 Author: bossenti <[email protected]> AuthorDate: Sun Jan 22 14:40:26 2023 +0100 simplify import of broker classes Signed-off-by: bossenti <[email protected]> --- .../streampipes_client/functions/broker/__init__.py | 8 ++++++++ .../streampipes_client/functions/function_handler.py | 3 +-- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/streampipes-client-python/streampipes_client/functions/broker/__init__.py b/streampipes-client-python/streampipes_client/functions/broker/__init__.py index cce3acad3..509c6b0d2 100644 --- a/streampipes-client-python/streampipes_client/functions/broker/__init__.py +++ b/streampipes-client-python/streampipes_client/functions/broker/__init__.py @@ -14,3 +14,11 @@ # See the License for the specific language governing permissions and # limitations under the License. # +from .broker import Broker, SupportedBroker +from .nats_broker import NatsBroker + +__all__ = [ + "Broker", + "NatsBroker", + "SupportedBroker" +] \ No newline at end of file diff --git a/streampipes-client-python/streampipes_client/functions/function_handler.py b/streampipes-client-python/streampipes_client/functions/function_handler.py index a0e6bfe6e..5097468cb 100644 --- a/streampipes-client-python/streampipes_client/functions/function_handler.py +++ b/streampipes-client-python/streampipes_client/functions/function_handler.py @@ -20,8 +20,7 @@ import logging from typing import AsyncIterator, Dict, List from streampipes_client.client.client import StreamPipesClient -from streampipes_client.functions.broker.broker import Broker, SupportedBroker -from streampipes_client.functions.broker.nats_broker import NatsBroker +from streampipes_client.functions.broker import Broker, NatsBroker, SupportedBroker from streampipes_client.functions.registration import Registration from streampipes_client.functions.utils.async_iter_handler import AsyncIterHandler from streampipes_client.functions.utils.data_stream_context import DataStreamContext
