We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 88dd505 + f189e47 commit 71bf32eCopy full SHA for 71bf32e
api/backend/app/controllers/health.py
@@ -87,7 +87,7 @@ async def database_health_check():
87
async def kafka_health_check():
88
last_poll_timestamp = await kafka_service.fetch_latest_poll_timestamp()
89
current_timestamp = int(datetime.timestamp(datetime.now()) * 1000)
90
- if last_poll_timestamp and 30000 > (current_timestamp - last_poll_timestamp) > 0:
+ if last_poll_timestamp and 60000 > (current_timestamp - last_poll_timestamp) > 0:
91
return True
92
print("time difference : ", current_timestamp - last_poll_timestamp)
93
return False
0 commit comments