[openwhisk-package-kafka] branch master updated: Do not update last canary everytime a database connection attempt occurs (#356)

[ja...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new a2fe946  Do not update last canary everytime a database connection attempt occurs (#356)
a2fe946 is described below

commit a2fe946531a8c7585f6e2d7db59745963cf7111e
Author: James Dubee <jw...@us.ibm.com>
AuthorDate: Tue Nov 12 10:37:00 2019 -0500

    Do not update last canary everytime a database connection attempt occurs (#356)
---
 provider/service.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/provider/service.py b/provider/service.py
index ae970bb..fa8e109 100644
--- a/provider/service.py
+++ b/provider/service.py
@@ -50,6 +50,7 @@ class Service (Thread):
 
     def run(self):
         self.canaryGenerator.start()
+        self.lastCanaryTime = datetime.now()
 
         while True:
             try:
@@ -61,8 +62,6 @@ class Service (Thread):
                 self.database = Database(timeout=changesFeedTimeout)
                 self.changes = self.database.changesFeed(timeout=changesFeedTimeout, since=self.lastSequence)
 
-                self.lastCanaryTime = datetime.now()
-
                 for change in self.changes:
                     # change could be None because the changes feed will timeout
                     # if it hasn't detected any changes. This timeout allows us to