From b053c7e576272a9176648190830cb54adcf737ea Mon Sep 17 00:00:00 2001
From: Stefan Allius <122395479+s-allius@users.noreply.github.com>
Date: Sun, 16 Jun 2024 02:08:15 +0200
Subject: [PATCH] Update async_stream.py

- check if processing time is < 5 sec
---
 app/src/async_stream.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/src/async_stream.py b/app/src/async_stream.py
index 39d0cdb..513ab8e 100644
--- a/app/src/async_stream.py
+++ b/app/src/async_stream.py
@@ -116,7 +116,7 @@ class AsyncStream():
         logging.debug('async_stream healthy() elapsed: '
                       f'{round(1000*elapsed)}ms'
                       f' max:{round(1000*self.proc_max)}ms')
-        return True
+        return elapsed < 5
 
     '''
     Our private methods