[incubator-openwhisk-package-kafka] branch master updated: Restart changes feed on all exceptions (#213)

[cs...@apache.org]

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

csantanapr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk-package-kafka.git


The following commit(s) were added to refs/heads/master by this push:
     new 289671f  Restart changes feed on all exceptions (#213)
289671f is described below

commit 289671f5da21c7ae41c75e1e10c87e5e66d9eea4
Author: Justin Berstler <bj...@us.ibm.com>
AuthorDate: Mon Aug 14 11:57:24 2017 -0400

    Restart changes feed on all exceptions (#213)
---
 provider/service.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/provider/service.py b/provider/service.py
index 6a6e6ae..8a08e79 100644
--- a/provider/service.py
+++ b/provider/service.py
@@ -113,8 +113,9 @@ class Service (Thread):
                             self.lastCanaryTime = datetime.now()
                         else:
                             logging.debug('[changes] Found a change for a non-trigger document')
-            except (ConnectionError, ReadTimeout):
-                logging.error('[canary] DB connection timed out. Restarting changes feed...')
+            except Exception as e:
+                logging.error('[canary] Exception caught from changes feed. Restarting changes feed...')
+                logging.error(e)
                 self.stopChangesFeed()
 
             logging.debug("[changes] I made it out of the changes loop!")

-- 
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <co...@openwhisk.apache.org>'].