Working with async graphql db sessions; Tests broken

[Mark90]

No description provided.

[pboers1988]

Living on the edge curious if you guys can get it to work without the locking problem.

[Mark90]

Had to change our context_getter from

def surf_context_getter(
    auth_manager: AuthManager,
    graphql_models: StrawberryModelType,
    broadcast_thread: ProcessDataBroadcastThread | None = None,
) -> Callable[[], Coroutine[Any, Any, SurfOrchestratorContext]]:
    async def context_getter() -> SurfOrchestratorContext:
        return SurfOrchestratorContext(
            auth_manager=auth_manager, graphql_models=graphql_models, broadcast_thread=broadcast_thread
        )

    return context_getter

to

from collections.abc import AsyncIterator
from orchestrator.db import async_db


def surf_context_getter(
    auth_manager: AuthManager,
    graphql_models: StrawberryModelType,
    broadcast_thread: ProcessDataBroadcastThread | None = None,
) -> Callable[[], AsyncIterator[SurfOrchestratorContext]]:
    async def context_getter() -> AsyncIterator[SurfOrchestratorContext]:
        async with async_db.session() as session:
            yield SurfOrchestratorContext(
                auth_manager=auth_manager,
                graphql_models=graphql_models,
                broadcast_thread=broadcast_thread,
                db_session=session,
            )