diff --git a/doublethink/services.py b/doublethink/services.py index 38a0f93..f764284 100644 --- a/doublethink/services.py +++ b/doublethink/services.py @@ -276,7 +276,7 @@ def healthy_service(self, role): ''' try: result = self.rr.table('services').get_all(role, index='role').filter( - lambda svc: r.now().sub(svc["last_heartbeat"]) < svc["ttl"] + lambda svc: r.now().sub(svc["last_heartbeat"]).lt(svc["ttl"]) ).order_by("load")[0].run() return result except r.ReqlNonExistenceError: @@ -302,7 +302,7 @@ def healthy_services(self, role=None): if role: query = query.get_all(role, index='role') query = query.filter( - lambda svc: r.now().sub(svc["last_heartbeat"]) < svc["ttl"] #.default(20.0) + lambda svc: r.now().sub(svc["last_heartbeat"]).lt(svc["ttl"]) #.default(20.0) ).order_by("load") result = query.run() return result