We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 81c27f2 + c30c3a5 commit b55d9e3Copy full SHA for b55d9e3
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 60000 > (current_timestamp - last_poll_timestamp) > 0:
+ if last_poll_timestamp and 300000 > (current_timestamp - last_poll_timestamp) > 0:
91
return True
92
print(f"last_poll_timestamp: {last_poll_timestamp}, current_timestamp: {current_timestamp}")
93
print("time difference : ", current_timestamp - last_poll_timestamp if last_poll_timestamp else 0)
0 commit comments