Added healthy status for page
This commit is contained in:
@@ -7,6 +7,7 @@ class FlaskPageThread(Thread):
|
|||||||
self.func = func
|
self.func = func
|
||||||
self.args = args
|
self.args = args
|
||||||
self.page = ("init", 500)
|
self.page = ("init", 500)
|
||||||
|
self.hhealthy = False
|
||||||
name = kwargs.get("name", "FlaskPageThread")
|
name = kwargs.get("name", "FlaskPageThread")
|
||||||
super().__init__(target=self.run, daemon=True, name=name)
|
super().__init__(target=self.run, daemon=True, name=name)
|
||||||
|
|
||||||
@@ -14,9 +15,11 @@ class FlaskPageThread(Thread):
|
|||||||
try:
|
try:
|
||||||
data = self.func(*self.args)
|
data = self.func(*self.args)
|
||||||
self.page = (data, 200)
|
self.page = (data, 200)
|
||||||
|
self.hhealthy = True
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print("Exception: %s" % e)
|
print("Exception: %s" % e)
|
||||||
self.page = ("Internal error", 500)
|
self.page = ("Internal error", 500)
|
||||||
|
self.hhealthy = False
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
self.genpage()
|
self.genpage()
|
||||||
|
Reference in New Issue
Block a user