We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 81c27f2 commit c30c3a5Copy full SHA for c30c3a5
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