Skip to content

Commit f189e47

Browse files
committed
fix: fix api health check for kafka in api
1 parent 88dd505 commit f189e47

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

api/backend/app/controllers/health.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ async def database_health_check():
8787
async def kafka_health_check():
8888
last_poll_timestamp = await kafka_service.fetch_latest_poll_timestamp()
8989
current_timestamp = int(datetime.timestamp(datetime.now()) * 1000)
90-
if last_poll_timestamp and 30000 > (current_timestamp - last_poll_timestamp) > 0:
90+
if last_poll_timestamp and 60000 > (current_timestamp - last_poll_timestamp) > 0:
9191
return True
9292
print("time difference : ", current_timestamp - last_poll_timestamp)
9393
return False

0 commit comments

Comments
 (0)