birbnetes/input-service
birbnetes/input-service
4
0
Fork 0
Code Pull Requests Releases Activity

Lowered warning tresholds
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Pünkösd Marcell 2021-07-26 17:07:55 +02:00
parent 67c5d723ca
commit 414330b3d5
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/magic_ampq.py
View File

@ -53,7 +53,7 @@ class MagicAMPQ:
lock_start = time.time() lock_start = time.time()
with self._lock: with self._lock:
lock_acquire_time = time.time() - lock_start lock_acquire_time = time.time() - lock_start
if lock_acquire_time >= 1.5: if lock_acquire_time >= 0.5:
self.app.logger.warning(f"Loop: Lock acquire took {lock_acquire_time:5f} sec") self.app.logger.warning(f"Loop: Lock acquire took {lock_acquire_time:5f} sec")
try: try:
@ -64,7 +64,7 @@ class MagicAMPQ:
self._reconnect_ampq() self._reconnect_ampq()
total_time = time.time() - lock_start total_time = time.time() - lock_start
if total_time > 2: if total_time > 1:
self.app.logger.warning(f"Loop: Total loop took {total_time:5f} sec") self.app.logger.warning(f"Loop: Total loop took {total_time:5f} sec")
def publish(self, payload=None): def publish(self, payload=None):
@ -75,7 +75,7 @@ class MagicAMPQ:
lock_start = time.time() lock_start = time.time()
with self._lock: with self._lock:
lock_acquire_time = time.time() - lock_start lock_acquire_time = time.time() - lock_start
if lock_acquire_time >= 0.3: if lock_acquire_time >= 0.2:
self.app.logger.warning(f"Publish: Lock acquire took {lock_acquire_time:5f} sec") self.app.logger.warning(f"Publish: Lock acquire took {lock_acquire_time:5f} sec")
tries = 0 tries = 0
while True: while True:
@ -106,7 +106,7 @@ class MagicAMPQ:
if tries > 10: if tries > 10:
time.sleep(2) time.sleep(2)
total_time = time.time() - lock_start total_time = time.time() - lock_start
if total_time > 0.5: if total_time > 0.4:
self.app.logger.warning(f"Publish: Total publish took {total_time:5f} sec") self.app.logger.warning(f"Publish: Total publish took {total_time:5f} sec")
def is_healthy(self) -> bool: def is_healthy(self) -> bool:

2
src/resources.py
View File

@ -100,7 +100,7 @@ class SampleResource(Resource):
) )
upload_time = time.time() - upload_started upload_time = time.time() - upload_started
if upload_time > 0.9: if upload_time > 0.8:
current_app.logger.warning(f"Uploading to storage-service took {upload_time:5} sec") current_app.logger.warning(f"Uploading to storage-service took {upload_time:5} sec")
if r.status_code not in [200, 201]: if r.status_code not in [200, 201]: