Function initialize

methods/MIRIX/mirix/server/rest_api.py:86–127

Initialize the Mirix server and queue services. This function can be called by external applications to initialize the server.

()

async def initialize():
    """
    Initialize the Mirix server and queue services.
    This function can be called by external applications to initialize the server.
    """
    logger.info("Starting Mirix REST API server")

    # Create database tables (async engine) before initializing server
    await ensure_tables_created()

    # Initialize Redis (async ping, create_indexes, log stats)
    try:
        from mirix.database.redis_client import get_redis_client

        redis_client = get_redis_client()
        if redis_client:
            if await redis_client.ping():
                await redis_client.create_indexes()
                await redis_client.log_connection_stats()
                logger.info("Redis async client ready")
            else:
                logger.warning("Redis ping failed - continuing without Redis")
    except Exception as e:
        logger.warning("Redis async init failed: %s", e)

    # Initialize AsyncServer (singleton) and create default org/user/client
    server = get_server()
    await server.ensure_defaults()
    logger.info("AsyncServer initialized")

    # Initialize queue with server reference
    await initialize_queue(server)
    logger.info("Queue service started with AsyncServer integration")

    # Initialize LangFuse observability (async)
    try:
        from mirix.observability import initialize_langfuse

        logger.info("Initializing LangFuse observability...")
        await initialize_langfuse()
    except Exception as e:
        logger.warning(f"LangFuse initialization failed: {e}. Continuing without observability.")


async def cleanup():