This commit is contained in:
@@ -9,6 +9,7 @@ import time
|
|||||||
import logging
|
import logging
|
||||||
import requests
|
import requests
|
||||||
import docker
|
import docker
|
||||||
|
import json
|
||||||
from urllib.parse import quote
|
from urllib.parse import quote
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
|
||||||
@@ -67,7 +68,7 @@ class PuppeteerHealthcheck:
|
|||||||
try:
|
try:
|
||||||
# Construct the URL with the test URL as a parameter
|
# Construct the URL with the test URL as a parameter
|
||||||
encoded_test_url = quote(self.test_url, safe='')
|
encoded_test_url = quote(self.test_url, safe='')
|
||||||
url = f"{self.base_url}/?url={encoded_test_url}"
|
url = f"{self.base_url}/?url={encoded_test_url}&skipCache=true"
|
||||||
|
|
||||||
headers = {
|
headers = {
|
||||||
'x-api-key': self.api_key,
|
'x-api-key': self.api_key,
|
||||||
@@ -84,8 +85,21 @@ class PuppeteerHealthcheck:
|
|||||||
)
|
)
|
||||||
|
|
||||||
if response.status_code == 200:
|
if response.status_code == 200:
|
||||||
logger.info("Health check passed - API is responding correctly")
|
# Check if the response body indicates an error
|
||||||
return True
|
try:
|
||||||
|
response_data = response.json()
|
||||||
|
if response_data.get('status') == 'error':
|
||||||
|
logger.warning(f"Health check failed - API returned status: error")
|
||||||
|
logger.warning(f"Response: {response.text[:200]}...")
|
||||||
|
return False
|
||||||
|
else:
|
||||||
|
logger.info("Health check passed - API is responding correctly")
|
||||||
|
return True
|
||||||
|
except json.JSONDecodeError:
|
||||||
|
# If response is not JSON, treat as success (backward compatibility)
|
||||||
|
logger.info("Health check passed - API is responding correctly (non-JSON response)")
|
||||||
|
return True
|
||||||
|
|
||||||
else:
|
else:
|
||||||
logger.warning(f"Health check failed - Status code: {response.status_code}")
|
logger.warning(f"Health check failed - Status code: {response.status_code}")
|
||||||
logger.warning(f"Response: {response.text[:200]}...")
|
logger.warning(f"Response: {response.text[:200]}...")
|
||||||
|
|||||||
Reference in New Issue
Block a user