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 <[email protected]>
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
