async def METHOD_NAME(connection: SAConnection):
    for service in FAKE_FILE_CONSUMER_SERVICES:
        await connection.execute(
            services_meta_data.insert().values(
                key=service["key"],
                version=service["version"],
                name=service["display_name"],
                description=service["display_name"],
            )
        )
        for n, consumable in enumerate(service["consumes"]):
            filetype, port, *_ = consumable.split(":") + ["input_1"]
            result: ResultProxy = await connection.execute(
                services_consume_filetypes.insert().values(
                    service_key=service["key"],
                    service_version=service["version"],
                    service_display_name=service["display_name"],
                    service_input_port=port,
                    filetype=filetype,
                    preference_order=n,
                )
            )
            assert result.closed
            assert not result.returns_rows
            with pytest.raises(ResourceClosedError):
                await result.scalar()