Add logging for Google CSE request parameters and update Qdrant client URL configuration
parent
96bd923387
commit
40e3e26eef
|
|
@ -40,7 +40,7 @@ class CustomSearchService:
|
||||||
}
|
}
|
||||||
if extra_params:
|
if extra_params:
|
||||||
params.update(extra_params)
|
params.update(extra_params)
|
||||||
|
print(f"Making request to Google CSE with params: {params}")
|
||||||
async with httpx.AsyncClient(timeout=self.timeout) as client:
|
async with httpx.AsyncClient(timeout=self.timeout) as client:
|
||||||
response = await client.get(GOOGLE_CSE_ENDPOINT, params=params)
|
response = await client.get(GOOGLE_CSE_ENDPOINT, params=params)
|
||||||
response.raise_for_status()
|
response.raise_for_status()
|
||||||
|
|
|
||||||
|
|
@ -25,8 +25,8 @@ DATABASE_URL = URL.create(
|
||||||
|
|
||||||
|
|
||||||
async def get_qdrant_client()->AsyncGenerator[AsyncQdrantClient,None]:
|
async def get_qdrant_client()->AsyncGenerator[AsyncQdrantClient,None]:
|
||||||
# Replace with your Qdrant URL
|
qdrant_url = os.getenv("QDRANT_URL", "http://localhost:6333")
|
||||||
client = AsyncQdrantClient(url="http://localhost:6333", timeout=60)
|
client = AsyncQdrantClient(url=qdrant_url, timeout=60)
|
||||||
try:
|
try:
|
||||||
yield client
|
yield client
|
||||||
finally:
|
finally:
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue