class Multiwoven::Integrations::Source::VertexModel::Client

def run_model(connection_config, payload)
  create_connection(connection_config)
  http_body = Google::Api::HttpBody.new(data: JSON.generate(payload))
  response = @endpoint.raw_predict(endpoint: build_url(GOOGLE_VERTEX_MODEL_NAME, connection_config), http_body: http_body)
  process_response(response)
rescue StandardError => e
  handle_exception(e, context: "GOOGLE:VERTEX MODEL:RUN_MODEL:EXCEPTION", type: "error")
end