You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/08/03 20:18:46 UTC

[incubator-streampipes] branch dev updated: [STREAMPIPES-185][hotfix] remove print command

This is an automated email from the ASF dual-hosted git repository.

wiener pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 67ca8d0  [STREAMPIPES-185][hotfix] remove print command
67ca8d0 is described below

commit 67ca8d030b2bc74efc8c885e18346212eb19a11d
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Mon Aug 3 22:18:32 2020 +0200

    [STREAMPIPES-185][hotfix] remove print command
---
 streampipes-wrapper-python/streampipes/utils/register.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/streampipes-wrapper-python/streampipes/utils/register.py b/streampipes-wrapper-python/streampipes/utils/register.py
index 01db4d6..be906ae 100644
--- a/streampipes-wrapper-python/streampipes/utils/register.py
+++ b/streampipes-wrapper-python/streampipes/utils/register.py
@@ -40,7 +40,6 @@ class ConsulUtils(object):
         if not port:
             raise ValueError
 
-        print('register service at consul for key: {}'.format(app_id))
         self.consul.agent.service.register(name='pe',
                                            service_id=app_id,
                                            address=host,
@@ -93,7 +92,6 @@ class ConsulUtils(object):
         index, data = self.consul.kv.get(key)
         # TODO: update existing keys?
         if data is None:
-            print('register config item at consul for key: {}'.format(env_key))
             self.consul.kv.put(key, config_item.to_json())
 
     def _get_consul_key(self, app_id, key):