patent siren
What's the correct way to call dagger under FastAPI server.
Right now having
async with dagger.connection(dagger.Config(log_output=open(os.devnull, "w"))):
inside api handler results in frequent
dagger.ClientConnectionError: Failed to establish client connection to the Dagger session: No active engine session to connect to
Any recipe to keep clean session active during application lifetime that I'm no aware of?
stray jacinth
👋 just checking if you've seen this thread by any chance: #1369369475219984514 message
chilly venture
This page also has information on how to embed/use Dagger inside of an existing application: https://docs.dagger.io/api/sdk/?sdk=python#custom-applications
patent siren
The issue in isolation is illustrated here
async def dummy_task():
async with dagger.connection(dagger.Config(log_output=open(os.devnull, "w"))):
await anyio.sleep(1.0)
async def dummy_main():
async with anyio.create_task_group() as tg:
for i in range(10):
tg.start_soon(dummy_task)
Any entry into context manager causes client to break.
Exactly this happens whenever any fastapi endpoints are hit concurrently.
I solved the problem using isolated clients
async with dagger.Connection(dagger.Config(log_output=open(os.devnull, "w"))) as client:
However maybe better solutions exist.