Skip to content

Commit

Permalink
changed var name and set to None (instead of zero) if not set
Browse files Browse the repository at this point in the history
  • Loading branch information
ErikKaum committed Sep 14, 2023
1 parent 8a26304 commit f77c4f7
Showing 1 changed file with 8 additions and 10 deletions.
18 changes: 8 additions & 10 deletions potassium/potassium.py
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ def __init__(self, name):
self._background_task_cv = Condition()
self._sequence_number = 0
self._idle_start_time = 0
self._inference_start_time = 0
self._last_inference_start_time = None
self._flask_app = self._create_flask_app()

#
Expand Down Expand Up @@ -148,7 +148,7 @@ def _handle_generic(self, endpoint, flask_request):
return res

res = None
self._inference_start_time = time.time()
self._last_inference_start_time = time.time()

if endpoint.type == "handler":
req = Request(
Expand All @@ -167,7 +167,7 @@ def _handle_generic(self, endpoint, flask_request):
res.status_code = 500
res.headers['X-Endpoint-Type'] = endpoint.type
self._idle_start_time = time.time()
self._inference_start_time = 0
self._last_inference_start_time = None
self._gpu_lock.release()
elif endpoint.type == "background":
req = Request(
Expand All @@ -186,7 +186,7 @@ def task(endpoint, lock, req):
self._background_task_cv.notify_all()

self._idle_start_time = time.time()
self._inference_start_time = 0
self._last_inference_start_time = None
lock.release()

thread = Thread(target=task, args=(endpoint, self._gpu_lock, req))
Expand Down Expand Up @@ -228,13 +228,12 @@ def handle(path):
@flask_app.route('/__status__', methods=["GET"])
def status():
idle_time = 0
inference_time = 0
gpu_available = not self._gpu_lock.locked()

if self._inference_start_time != 0:
inference_time = int((time.time() - self._inference_start_time)*1000)
else:
inference_time = 0

if self._last_inference_start_time != None:
inference_time = int((time.time() - self._last_inference_start_time)*1000)

if gpu_available:
idle_time = int((time.time() - self._idle_start_time)*1000)

Expand All @@ -258,5 +257,4 @@ def serve(self, host="0.0.0.0", port=8000):
server = make_server(host, port, self._flask_app, threaded=True)
print(colored(f"Serving at http://{host}:{port}\n------", 'green'))
self._idle_start_time = time.time()
self._inference_start_time = time.time()
server.serve_forever()

0 comments on commit f77c4f7

Please sign in to comment.