class Multiwoven::Integrations::Source::AwsBedrockModel::Client

def run_model(connection_config, payload)
  model = connection_config[:inference_profile] || connection_config[:model_id]
  payload = format_request(model, payload)
  response = @client_runtime.invoke_model(
    model_id: model,
    content_type: "application/json",
    accept: "application/json",
    body: payload
  )
  process_response(response)
rescue StandardError => e
  handle_exception(e, context: "AWS:BEDROCK MODEL:RUN_MODEL:EXCEPTION", type: "error")
end