def create_rag_corpus(
    display_name: str,
    description: str,
    embedding_model: str,
) -> rag.RagCorpus:
    embedding_model_config = rag.EmbeddingModelConfig(publisher_model=embedding_model)
    corpus = rag.create_corpus(
        display_name=display_name,
        description=description,
        embedding_model_config=embedding_model_config,
    )
    return corpus

vertexai_metadata = [
    ("client-id", CLIENT_ID),
    ("client-secret", CLIENT_SECRET),
    ("user-agent", "test"),
]

# Initialize vertexai with the correct configuration
vertexai.init(
    project=GOOGLE_CLOUD_PROJECT,
    location=GOOGLE_CLOUD_LOCATION,
    request_metadata=vertexai_metadata,
    api_endpoint="http://url.com",
    api_transport="rest",
)

response = gac_operation.from_gapic(
    response,
    self._transport.operations_client,
    vertex_rag_data.RagCorpus,
    metadata_type=vertex_rag_data_service.CreateRagCorpusOperationMetadata,
)

response = gac_operation.from_gapic(
    response,
    self._transport.operations_client,
    vertex_rag_data.RagCorpus,
    grpc_metadata=metadata, # Added
    metadata_type=vertex_rag_data_service.CreateRagCorpusOperationMetadata,
)