Function get_async_supabase

app/api/agentops/api/db/supabase_client.py:38–55

FastAPI dependency to get the async Supabase client. This allows for proper dependency injection and easier testing. Returns: AsyncSupabase: The async Supabase client instance

()

async def get_async_supabase():
    """
    FastAPI dependency to get the async Supabase client.
    This allows for proper dependency injection and easier testing.

    Returns:
        AsyncSupabase: The async Supabase client instance
    """

    from agentops.api.environment import SUPABASE_KEY, SUPABASE_URL

    global async_supabase
    if async_supabase is None:
        async with _async_supabase_lock:
            # Check again inside the lock to prevent race conditions
            if async_supabase is None:
                async_supabase = AsyncSupabase(SUPABASE_URL, SUPABASE_KEY)
    return async_supabase


# Annotated dependencies for better type hinting