fix tools

This commit is contained in:
Daniel O'Connell 2025-06-03 22:48:12 +02:00
parent 69cf2844f9
commit ac9bdb1dfc
3 changed files with 6 additions and 12 deletions

View File

@ -83,8 +83,6 @@ services:
interval: 10s interval: 10s
timeout: 5s timeout: 5s
retries: 5 retries: 5
mem_limit: 4g
cpus: "1.5"
security_opt: [ "no-new-privileges=true" ] security_opt: [ "no-new-privileges=true" ]
migrate: migrate:
@ -117,8 +115,6 @@ services:
interval: 15s interval: 15s
timeout: 5s timeout: 5s
retries: 5 retries: 5
mem_limit: 512m
cpus: "0.5"
security_opt: [ "no-new-privileges=true" ] security_opt: [ "no-new-privileges=true" ]
qdrant: qdrant:
@ -136,8 +132,6 @@ services:
interval: 15s interval: 15s
timeout: 5s timeout: 5s
retries: 5 retries: 5
mem_limit: 4g
cpus: "2"
security_opt: [ "no-new-privileges=true" ] security_opt: [ "no-new-privileges=true" ]
cap_drop: [ ALL ] cap_drop: [ ALL ]
@ -161,8 +155,6 @@ services:
retries: 5 retries: 5
ports: ports:
- "8000:8000" - "8000:8000"
mem_limit: 768m
cpus: "1"
proxy: proxy:
build: build:
@ -181,8 +173,6 @@ services:
- ./tools:/app/tools:ro - ./tools:/app/tools:ro
ports: ports:
- "8001:8001" - "8001:8001"
mem_limit: 256m
cpus: "0.5"
# ------------------------------------------------------------ Celery workers # ------------------------------------------------------------ Celery workers
worker: worker:

View File

@ -13,7 +13,9 @@ if __name__ == "__main__":
args = args.parse_args() args = args.parse_args()
with make_session() as session: with make_session() as session:
user = User(email=args.email, password=args.password, name=args.name) user = User.create_with_password(
email=args.email, password=args.password, name=args.name
)
session.add(user) session.add(user)
session.commit() session.commit()

View File

@ -76,6 +76,7 @@ async def proxy_request(request: Request) -> Response:
# Get request body # Get request body
body = await request.body() body = await request.body()
headers = dict(request.headers) headers = dict(request.headers)
headers.pop("host", None)
async with httpx.AsyncClient() as client: async with httpx.AsyncClient() as client:
try: try:
@ -88,12 +89,13 @@ async def proxy_request(request: Request) -> Response:
) )
# Forward response # Forward response
return Response( resp = Response(
content=response.content, content=response.content,
status_code=response.status_code, status_code=response.status_code,
headers=dict(response.headers), headers=dict(response.headers),
media_type=response.headers.get("content-type"), media_type=response.headers.get("content-type"),
) )
return resp
except httpx.RequestError as e: except httpx.RequestError as e:
print(f"Request failed: {e}") print(f"Request failed: {e}")