From 4e7734d32718ce9ffd1a4855cb2eea7d2c87d72e Mon Sep 17 00:00:00 2001 From: Viktor Barzin Date: Sat, 26 Jul 2025 13:06:28 +0000 Subject: [PATCH] add healtcheck api endpoint --- crawler/api/app.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/crawler/api/app.py b/crawler/api/app.py index eec5d9a..fb48a4a 100644 --- a/crawler/api/app.py +++ b/crawler/api/app.py @@ -58,6 +58,11 @@ app.add_middleware( ) +@app.get("/api/status") +async def get_status(): + return {"status": "OK"} + + @app.get("/api/listing") async def get_listing(user: Annotated[User, Depends(get_current_user)]): repository = ListingRepository(engine) @@ -83,7 +88,9 @@ async def refresh_listings( user: Annotated[User, Depends(get_current_user)], query_parameters: Annotated[QueryParameters, Query()], ) -> dict[str, str]: - await send_notification(f"{user.email} refreshing listings with query parameters {query_parameters.model_dump_json()}") + await send_notification( + f"{user.email} refreshing listings with query parameters {query_parameters.model_dump_json()}" + ) # TODO: rate limit expiry_time = datetime.now() + timedelta(minutes=10) task = listing_tasks.dump_listings_task.apply_async(