Git-Mirrors/brozzler
1
0
Fork 0
mirror of https://github.com/internetarchive/brozzler.git synced 2025-04-20 23:56:34 -04:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

recover from rethinkdb error updating service registry

Browse Source
This commit is contained in:
Noah Levitt 2016-05-03 08:02:59 +00:00
parent f285be71fb
commit 1d21f2c307
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
brozzler/worker.py
View File

@ -312,14 +312,20 @@ class BrozzlerWorker:
status_info["browser_pool_size"] = self._browser_pool.size
status_info["browsers_in_use"] = self._browser_pool.num_in_use()
self.status_info = self._service_registry.heartbeat(status_info)
self.logger.debug("status in service registry: %s", self.status_info)
try:
self.status_info = self._service_registry.heartbeat(status_info)
self.logger.debug(
"status in service registry: %s", self.status_info)
except rethinkdb.ReqlError as e:
self.logger.error(
"failed to send heartbeat and update service registry "
"with info %s: %s", status_info, e)
def run(self):
try:
latest_state = None
while not self._shutdown_requested.is_set():
if self._service_registry and (not hasattr(self, "status_info") or (datetime.datetime.now(datetime.timezone.utc) - self.status_info["last_heartbeat"]).total_seconds() > self.HEARTBEAT_INTERVAL):
if self._service_registry and (not hasattr(self, "status_info") or (rethinkstuff.utcnow() - self.status_info["last_heartbeat"]).total_seconds() > self.HEARTBEAT_INTERVAL):
self._service_heartbeat()
try: