We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 76ed470 commit a2fe946Copy full SHA for a2fe946
provider/service.py
@@ -50,6 +50,7 @@ def __init__(self, consumers):
50
51
def run(self):
52
self.canaryGenerator.start()
53
+ self.lastCanaryTime = datetime.now()
54
55
while True:
56
try:
@@ -61,8 +62,6 @@ def run(self):
61
62
self.database = Database(timeout=changesFeedTimeout)
63
self.changes = self.database.changesFeed(timeout=changesFeedTimeout, since=self.lastSequence)
64
- self.lastCanaryTime = datetime.now()
65
-
66
for change in self.changes:
67
# change could be None because the changes feed will timeout
68
# if it hasn't detected any changes. This timeout allows us to
0 commit comments