Function rq_client

tests/unit/storage_clients/_sql/test_sql_rq_client.py:37–47

A fixture for a SQL request queue client.

(
    configuration: Configuration,
)

@pytest.fixture
async def rq_client(
    configuration: Configuration,
) -> AsyncGenerator[SqlRequestQueueClient, None]:
    """A fixture for a SQL request queue client."""
    async with SqlStorageClient() as storage_client:
        client = await storage_client.create_rq_client(
            name='test-request-queue',
            configuration=configuration,
        )
        yield client
        await client.drop()


# Helper function that allows you to use inspect with an asynchronous engine