I am trying to deploy fasthtml app that uses mongodb search to get some information from the database, the problem is that after i deploy the project and made my first call to the search function it works fine, then anytime i try it again it get the following error:
Search error: Task <Task pending name='Task-10' coro=<Starlette.__call__() running at /var/task/starlette/applications.py:112> cb=[_run_until_complete_cb() at /var/lang/lib/python3.12/asyncio/base_events.py:182]> got Future <Future pending cb=[_chain_future.<locals>._call_check_cancel() at /var/lang/lib/python3.12/asyncio/futures.py:391]> attached to a different loop
code is is
```python
from fasthtml.common import *
from faq import create_faq
from motor.motor_asyncio import AsyncIOMotorClient
from pymongo import ASCENDING
import os
MONGO_URI = os.environ.get("MONGO_URI")
client = AsyncIOMotorClient(
MONGO_URI, serverSelectionTimeoutMS=60000, connectTimeoutMS=60000, connect=True
)
db = client.fastcalorie
foods_collection = db.calories
server_info = client.server_info()
print(server_info)
app, rt = fast_app(
debug=True,
)
def mk_search_input():
return Input(
id="search-input",
name="query",
placeholder="ابحث عن الطعام..",
required=True,
)
@rt("/search")
async def post(query: str):
try:
# Create a new cursor for each request
cursor = (
foods_collection.find(
{"$text": {"$search": query}}, {"score": {"$meta": "textScore"}}
)
.sort([("score", {"$meta": "textScore"})])
.limit(20)
)
# Explicitly await the results
results = []
async for doc in cursor:
results.append(doc)
if not results:
return Div("لا توجد نتائج", id="results-table")
header = Thead(
Tr(*map(Th, ["الاسم بالعربية", "Food", "السعرات الحرارية"])),
cls="bg-purple/10",
)
rows = [
Tr(
Td(
AX(
r["arabic_name"],
f"/food/{r['_id']}",
"results-table",
hx_push_url="true",
)
),
Td(r["name"]),
Td(r["calories"]),
cls="even:bg-purple/5",
)
for r in results
]
return Table(header, *rows, cls="w-full", id="results-table")
except Exception as e:
print(f"Search error: {str(e)}") # Add detailed error logging
return Div("حدث خطأ في البحث", id="results-table")
@rt("/food/{id}")
async def get(id: str):
from bson.objectid import ObjectId
food = await foods_collection.find_one({"_id": ObjectId(id)})
return Table(
*[Tr(Th(k), Td(v)) for k, v in food.items() if k != "_id"],
id="results-table",
)
@rt("/")
async def get():
header = Header(
Nav(
Ul(
Li(A("البحث الذكي", href="/")),
),
cls="container",
),
cls="navbar",
)
search_form = Form(
Group(mk_search_input(), Button("Search")),
hx_post="/search",
target_id="results-table",
hx_swap="innerHTML",
hx_preserve="true",
hx_indicator="#results-table",
)
return (
Title("كم كالوري"),
header,
Main(
H1("كم كالوري في .."),
search_form,
Div(id="results-table"),
create_faq(),
cls="container",
),
)
serve()
the project is using fasthtml which is a python package that sues htmx to create web applications similar to fastpi
