Source file cli.ml

(* generated by: awso-codegen generate-all --botocore-data vendor/botocore/botocore/data -o aws --runtime-dir lib/runtime/awso --cli-dir awso-cli *)
open Core
open Async
let json_arg = Command.Arg_type.create Yojson.Safe.from_string
let call ?endpoint_url ?profile ?region f m result_to_json error_to_json =
  let region =
    match region with
    | Some region -> Some (Awso.Region.of_string region)
    | None -> None in
  (Awso_async.Cfg.get_exn ?profile ?region ()) >>=
    (fun cfg ->
       (f ?endpoint_url ?cfg:(Some cfg) m) >>=
         (fun result ->
            match result with
            | Error err ->
                (match error_to_json with
                 | None ->
                     failwithf
                       "endpoint error, but no error values defined in boto"
                       ()
                 | Some to_json ->
                     let s = (err |> to_json) |> Yojson.Safe.to_string in
                     failwithf "AWS error: %s" s ())
            | Ok result ->
                ((match result_to_json with
                  | None -> print_endline "ok response from endpoint"
                  | Some to_json ->
                      ((result |> to_json) |> Yojson.Safe.to_string) |>
                        print_endline);
                 return ())))
let cancel_gremlin_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and queryId = flag "query-id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.cancel_gremlin_query
           (Values.CancelGremlinQueryInput.make ~queryId ())
           (Some Values.CancelGremlinQueryOutput.to_json)
           (Some Values.CancelGremlinQueryOutput.error_to_json)])
let cancel_loader_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and loadId = flag "load-id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.cancel_loader_job (Values.CancelLoaderJobInput.make ~loadId ())
           (Some Values.CancelLoaderJobOutput.to_json)
           (Some Values.CancelLoaderJobOutput.error_to_json)])
let cancel_m_l_data_processing_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and clean = flag "clean" (optional bool) ~doc:"BOOL Boolean"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.cancel_m_l_data_processing_job
           (Values.CancelMLDataProcessingJobInput.make ?neptuneIamRoleArn
              ?clean ~id ())
           (Some Values.CancelMLDataProcessingJobOutput.to_json)
           (Some Values.CancelMLDataProcessingJobOutput.error_to_json)])
let cancel_m_l_model_training_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and clean = flag "clean" (optional bool) ~doc:"BOOL Boolean"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.cancel_m_l_model_training_job
           (Values.CancelMLModelTrainingJobInput.make ?neptuneIamRoleArn
              ?clean ~id ())
           (Some Values.CancelMLModelTrainingJobOutput.to_json)
           (Some Values.CancelMLModelTrainingJobOutput.error_to_json)])
let cancel_m_l_model_transform_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and clean = flag "clean" (optional bool) ~doc:"BOOL Boolean"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.cancel_m_l_model_transform_job
           (Values.CancelMLModelTransformJobInput.make ?neptuneIamRoleArn
              ?clean ~id ())
           (Some Values.CancelMLModelTransformJobOutput.to_json)
           (Some Values.CancelMLModelTransformJobOutput.error_to_json)])
let cancel_open_cypher_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and silent = flag "silent" (optional bool) ~doc:"BOOL Boolean"
       and queryId = flag "query-id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.cancel_open_cypher_query
           (Values.CancelOpenCypherQueryInput.make ?silent ~queryId ())
           (Some Values.CancelOpenCypherQueryOutput.to_json)
           (Some Values.CancelOpenCypherQueryOutput.error_to_json)])
let create_m_l_endpoint =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and id = flag "id" (optional string) ~doc:"STRING String"
       and mlModelTrainingJobId =
         flag "ml-model-training-job-id" (optional string)
           ~doc:"STRING String"
       and mlModelTransformJobId =
         flag "ml-model-transform-job-id" (optional string)
           ~doc:"STRING String"
       and update = flag "update" (optional bool) ~doc:"BOOL Boolean"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and modelName =
         flag "model-name" (optional string) ~doc:"STRING String"
       and instanceType =
         flag "instance-type" (optional string) ~doc:"STRING String"
       and instanceCount =
         flag "instance-count" (optional int) ~doc:"INT Integer"
       and volumeEncryptionKMSKey =
         flag "volume-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.create_m_l_endpoint
           (Values.CreateMLEndpointInput.make ?id ?mlModelTrainingJobId
              ?mlModelTransformJobId ?update ?neptuneIamRoleArn ?modelName
              ?instanceType ?instanceCount ?volumeEncryptionKMSKey ())
           (Some Values.CreateMLEndpointOutput.to_json)
           (Some Values.CreateMLEndpointOutput.error_to_json)])
let delete_m_l_endpoint =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and clean = flag "clean" (optional bool) ~doc:"BOOL Boolean"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_m_l_endpoint
           (Values.DeleteMLEndpointInput.make ?neptuneIamRoleArn ?clean ~id
              ()) (Some Values.DeleteMLEndpointOutput.to_json)
           (Some Values.DeleteMLEndpointOutput.error_to_json)])
let delete_propertygraph_statistics =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and () = return () in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_propertygraph_statistics (Fn.id ())
           (Some Values.DeletePropertygraphStatisticsOutput.to_json)
           (Some Values.DeletePropertygraphStatisticsOutput.error_to_json)])
let delete_sparql_statistics =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and () = return () in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.delete_sparql_statistics (Fn.id ())
           (Some Values.DeleteSparqlStatisticsOutput.to_json)
           (Some Values.DeleteSparqlStatisticsOutput.error_to_json)])
let execute_fast_reset =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and token = flag "token" (optional string) ~doc:"STRING String"
       and action = flag "action" (required json_arg) ~doc:"JSON Action" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.execute_fast_reset
           (Values.ExecuteFastResetInput.make ?token
              ~action:(Values.Action.of_json action) ())
           (Some Values.ExecuteFastResetOutput.to_json)
           (Some Values.ExecuteFastResetOutput.error_to_json)])
let execute_gremlin_explain_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and gremlinQuery =
         flag "gremlin-query" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.execute_gremlin_explain_query
           (Values.ExecuteGremlinExplainQueryInput.make ~gremlinQuery ())
           (Some Values.ExecuteGremlinExplainQueryOutput.to_json)
           (Some Values.ExecuteGremlinExplainQueryOutput.error_to_json)])
let execute_gremlin_profile_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and results = flag "results" (optional bool) ~doc:"BOOL Boolean"
       and chop = flag "chop" (optional int) ~doc:"INT Integer"
       and serializer =
         flag "serializer" (optional string) ~doc:"STRING String"
       and indexOps = flag "index-ops" (optional bool) ~doc:"BOOL Boolean"
       and gremlinQuery =
         flag "gremlin-query" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.execute_gremlin_profile_query
           (Values.ExecuteGremlinProfileQueryInput.make ?results ?chop
              ?serializer ?indexOps ~gremlinQuery ())
           (Some Values.ExecuteGremlinProfileQueryOutput.to_json)
           (Some Values.ExecuteGremlinProfileQueryOutput.error_to_json)])
let execute_gremlin_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and serializer =
         flag "serializer" (optional string) ~doc:"STRING String"
       and gremlinQuery =
         flag "gremlin-query" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.execute_gremlin_query
           (Values.ExecuteGremlinQueryInput.make ?serializer ~gremlinQuery ())
           (Some Values.ExecuteGremlinQueryOutput.to_json)
           (Some Values.ExecuteGremlinQueryOutput.error_to_json)])
let execute_open_cypher_explain_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and parameters =
         flag "parameters" (optional string) ~doc:"STRING String"
       and openCypherQuery =
         flag "open-cypher-query" (required string) ~doc:"STRING String"
       and explainMode =
         flag "explain-mode" (required json_arg)
           ~doc:"JSON OpenCypherExplainMode" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.execute_open_cypher_explain_query
           (Values.ExecuteOpenCypherExplainQueryInput.make ?parameters
              ~openCypherQuery
              ~explainMode:(Values.OpenCypherExplainMode.of_json explainMode)
              ()) (Some Values.ExecuteOpenCypherExplainQueryOutput.to_json)
           (Some Values.ExecuteOpenCypherExplainQueryOutput.error_to_json)])
let execute_open_cypher_query =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and parameters =
         flag "parameters" (optional string) ~doc:"STRING String"
       and openCypherQuery =
         flag "open-cypher-query" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.execute_open_cypher_query
           (Values.ExecuteOpenCypherQueryInput.make ?parameters
              ~openCypherQuery ())
           (Some Values.ExecuteOpenCypherQueryOutput.to_json)
           (Some Values.ExecuteOpenCypherQueryOutput.error_to_json)])
let get_engine_status =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and () = return () in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_engine_status (Fn.id ())
           (Some Values.GetEngineStatusOutput.to_json)
           (Some Values.GetEngineStatusOutput.error_to_json)])
let get_gremlin_query_status =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and queryId = flag "query-id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_gremlin_query_status
           (Values.GetGremlinQueryStatusInput.make ~queryId ())
           (Some Values.GetGremlinQueryStatusOutput.to_json)
           (Some Values.GetGremlinQueryStatusOutput.error_to_json)])
let get_loader_job_status =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and details = flag "details" (optional bool) ~doc:"BOOL Boolean"
       and errors = flag "errors" (optional bool) ~doc:"BOOL Boolean"
       and page = flag "page" (optional int) ~doc:"INT PositiveInteger"
       and errorsPerPage =
         flag "errors-per-page" (optional int) ~doc:"INT PositiveInteger"
       and loadId = flag "load-id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_loader_job_status
           (Values.GetLoaderJobStatusInput.make ?details ?errors ?page
              ?errorsPerPage ~loadId ())
           (Some Values.GetLoaderJobStatusOutput.to_json)
           (Some Values.GetLoaderJobStatusOutput.error_to_json)])
let get_m_l_data_processing_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_m_l_data_processing_job
           (Values.GetMLDataProcessingJobInput.make ?neptuneIamRoleArn ~id ())
           (Some Values.GetMLDataProcessingJobOutput.to_json)
           (Some Values.GetMLDataProcessingJobOutput.error_to_json)])
let get_m_l_endpoint =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_m_l_endpoint
           (Values.GetMLEndpointInput.make ?neptuneIamRoleArn ~id ())
           (Some Values.GetMLEndpointOutput.to_json)
           (Some Values.GetMLEndpointOutput.error_to_json)])
let get_m_l_model_training_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_m_l_model_training_job
           (Values.GetMLModelTrainingJobInput.make ?neptuneIamRoleArn ~id ())
           (Some Values.GetMLModelTrainingJobOutput.to_json)
           (Some Values.GetMLModelTrainingJobOutput.error_to_json)])
let get_m_l_model_transform_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and id = flag "id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_m_l_model_transform_job
           (Values.GetMLModelTransformJobInput.make ?neptuneIamRoleArn ~id ())
           (Some Values.GetMLModelTransformJobOutput.to_json)
           (Some Values.GetMLModelTransformJobOutput.error_to_json)])
let get_open_cypher_query_status =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and queryId = flag "query-id" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_open_cypher_query_status
           (Values.GetOpenCypherQueryStatusInput.make ~queryId ())
           (Some Values.GetOpenCypherQueryStatusOutput.to_json)
           (Some Values.GetOpenCypherQueryStatusOutput.error_to_json)])
let get_propertygraph_statistics =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and () = return () in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_propertygraph_statistics (Fn.id ())
           (Some Values.GetPropertygraphStatisticsOutput.to_json)
           (Some Values.GetPropertygraphStatisticsOutput.error_to_json)])
let get_propertygraph_stream =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and limit =
         flag "limit" (optional json_arg)
           ~doc:"JSON GetPropertygraphStreamInputLimitLong"
       and iteratorType =
         flag "iterator-type" (optional json_arg) ~doc:"JSON IteratorType"
       and commitNum = flag "commit-num" (optional json_arg) ~doc:"JSON Long"
       and opNum = flag "op-num" (optional json_arg) ~doc:"JSON Long"
       and encoding =
         flag "encoding" (optional json_arg) ~doc:"JSON Encoding" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_propertygraph_stream
           (Values.GetPropertygraphStreamInput.make
              ?limit:(Option.map
                        ~f:Values.GetPropertygraphStreamInputLimitLong.of_json
                        limit)
              ?iteratorType:(Option.map ~f:Values.IteratorType.of_json
                               iteratorType)
              ?commitNum:(Option.map ~f:Values.Long.of_json commitNum)
              ?opNum:(Option.map ~f:Values.Long.of_json opNum)
              ?encoding:(Option.map ~f:Values.Encoding.of_json encoding) ())
           (Some Values.GetPropertygraphStreamOutput.to_json)
           (Some Values.GetPropertygraphStreamOutput.error_to_json)])
let get_propertygraph_summary =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and mode =
         flag "mode" (optional json_arg) ~doc:"JSON GraphSummaryType" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_propertygraph_summary
           (Values.GetPropertygraphSummaryInput.make
              ?mode:(Option.map ~f:Values.GraphSummaryType.of_json mode) ())
           (Some Values.GetPropertygraphSummaryOutput.to_json)
           (Some Values.GetPropertygraphSummaryOutput.error_to_json)])
let get_r_d_f_graph_summary =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and mode =
         flag "mode" (optional json_arg) ~doc:"JSON GraphSummaryType" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_r_d_f_graph_summary
           (Values.GetRDFGraphSummaryInput.make
              ?mode:(Option.map ~f:Values.GraphSummaryType.of_json mode) ())
           (Some Values.GetRDFGraphSummaryOutput.to_json)
           (Some Values.GetRDFGraphSummaryOutput.error_to_json)])
let get_sparql_statistics =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and () = return () in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_sparql_statistics (Fn.id ())
           (Some Values.GetSparqlStatisticsOutput.to_json)
           (Some Values.GetSparqlStatisticsOutput.error_to_json)])
let get_sparql_stream =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and limit =
         flag "limit" (optional json_arg)
           ~doc:"JSON GetSparqlStreamInputLimitLong"
       and iteratorType =
         flag "iterator-type" (optional json_arg) ~doc:"JSON IteratorType"
       and commitNum = flag "commit-num" (optional json_arg) ~doc:"JSON Long"
       and opNum = flag "op-num" (optional json_arg) ~doc:"JSON Long"
       and encoding =
         flag "encoding" (optional json_arg) ~doc:"JSON Encoding" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.get_sparql_stream
           (Values.GetSparqlStreamInput.make
              ?limit:(Option.map
                        ~f:Values.GetSparqlStreamInputLimitLong.of_json limit)
              ?iteratorType:(Option.map ~f:Values.IteratorType.of_json
                               iteratorType)
              ?commitNum:(Option.map ~f:Values.Long.of_json commitNum)
              ?opNum:(Option.map ~f:Values.Long.of_json opNum)
              ?encoding:(Option.map ~f:Values.Encoding.of_json encoding) ())
           (Some Values.GetSparqlStreamOutput.to_json)
           (Some Values.GetSparqlStreamOutput.error_to_json)])
let list_gremlin_queries =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and includeWaiting =
         flag "include-waiting" (optional bool) ~doc:"BOOL Boolean" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_gremlin_queries
           (Values.ListGremlinQueriesInput.make ?includeWaiting ())
           (Some Values.ListGremlinQueriesOutput.to_json)
           (Some Values.ListGremlinQueriesOutput.error_to_json)])
let list_loader_jobs =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and limit =
         flag "limit" (optional int)
           ~doc:"INT ListLoaderJobsInputLimitInteger"
       and includeQueuedLoads =
         flag "include-queued-loads" (optional bool) ~doc:"BOOL Boolean" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_loader_jobs
           (Values.ListLoaderJobsInput.make ?limit ?includeQueuedLoads ())
           (Some Values.ListLoaderJobsOutput.to_json)
           (Some Values.ListLoaderJobsOutput.error_to_json)])
let list_m_l_data_processing_jobs =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and maxItems =
         flag "max-items" (optional int)
           ~doc:"INT ListMLDataProcessingJobsInputMaxItemsInteger"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_m_l_data_processing_jobs
           (Values.ListMLDataProcessingJobsInput.make ?maxItems
              ?neptuneIamRoleArn ())
           (Some Values.ListMLDataProcessingJobsOutput.to_json)
           (Some Values.ListMLDataProcessingJobsOutput.error_to_json)])
let list_m_l_endpoints =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and maxItems =
         flag "max-items" (optional int)
           ~doc:"INT ListMLEndpointsInputMaxItemsInteger"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_m_l_endpoints
           (Values.ListMLEndpointsInput.make ?maxItems ?neptuneIamRoleArn ())
           (Some Values.ListMLEndpointsOutput.to_json)
           (Some Values.ListMLEndpointsOutput.error_to_json)])
let list_m_l_model_training_jobs =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and maxItems =
         flag "max-items" (optional int)
           ~doc:"INT ListMLModelTrainingJobsInputMaxItemsInteger"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_m_l_model_training_jobs
           (Values.ListMLModelTrainingJobsInput.make ?maxItems
              ?neptuneIamRoleArn ())
           (Some Values.ListMLModelTrainingJobsOutput.to_json)
           (Some Values.ListMLModelTrainingJobsOutput.error_to_json)])
let list_m_l_model_transform_jobs =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and maxItems =
         flag "max-items" (optional int)
           ~doc:"INT ListMLModelTransformJobsInputMaxItemsInteger"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_m_l_model_transform_jobs
           (Values.ListMLModelTransformJobsInput.make ?maxItems
              ?neptuneIamRoleArn ())
           (Some Values.ListMLModelTransformJobsOutput.to_json)
           (Some Values.ListMLModelTransformJobsOutput.error_to_json)])
let list_open_cypher_queries =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and includeWaiting =
         flag "include-waiting" (optional bool) ~doc:"BOOL Boolean" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.list_open_cypher_queries
           (Values.ListOpenCypherQueriesInput.make ?includeWaiting ())
           (Some Values.ListOpenCypherQueriesOutput.to_json)
           (Some Values.ListOpenCypherQueriesOutput.error_to_json)])
let manage_propertygraph_statistics =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and mode =
         flag "mode" (optional json_arg)
           ~doc:"JSON StatisticsAutoGenerationMode" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.manage_propertygraph_statistics
           (Values.ManagePropertygraphStatisticsInput.make
              ?mode:(Option.map
                       ~f:Values.StatisticsAutoGenerationMode.of_json mode)
              ()) (Some Values.ManagePropertygraphStatisticsOutput.to_json)
           (Some Values.ManagePropertygraphStatisticsOutput.error_to_json)])
let manage_sparql_statistics =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and mode =
         flag "mode" (optional json_arg)
           ~doc:"JSON StatisticsAutoGenerationMode" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.manage_sparql_statistics
           (Values.ManageSparqlStatisticsInput.make
              ?mode:(Option.map
                       ~f:Values.StatisticsAutoGenerationMode.of_json mode)
              ()) (Some Values.ManageSparqlStatisticsOutput.to_json)
           (Some Values.ManageSparqlStatisticsOutput.error_to_json)])
let start_loader_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and mode = flag "mode" (optional json_arg) ~doc:"JSON Mode"
       and failOnError =
         flag "fail-on-error" (optional bool) ~doc:"BOOL Boolean"
       and parallelism =
         flag "parallelism" (optional json_arg) ~doc:"JSON Parallelism"
       and parserConfiguration =
         flag "parser-configuration" (optional json_arg)
           ~doc:"JSON StringValuedMap"
       and updateSingleCardinalityProperties =
         flag "update-single-cardinality-properties" (optional bool)
           ~doc:"BOOL Boolean"
       and queueRequest =
         flag "queue-request" (optional bool) ~doc:"BOOL Boolean"
       and dependencies =
         flag "dependencies" (optional json_arg) ~doc:"JSON StringList"
       and userProvidedEdgeIds =
         flag "user-provided-edge-ids" (optional bool) ~doc:"BOOL Boolean"
       and edgeOnlyLoad =
         flag "edge-only-load" (optional bool) ~doc:"BOOL Boolean"
       and source = flag "source" (required string) ~doc:"STRING String"
       and format = flag "format" (required json_arg) ~doc:"JSON Format"
       and s3BucketRegion =
         flag "s3-bucket-region" (required json_arg)
           ~doc:"JSON S3BucketRegion"
       and iamRoleArn =
         flag "iam-role-arn" (required string) ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.start_loader_job
           (Values.StartLoaderJobInput.make
              ?mode:(Option.map ~f:Values.Mode.of_json mode) ?failOnError
              ?parallelism:(Option.map ~f:Values.Parallelism.of_json
                              parallelism)
              ?parserConfiguration:(Option.map
                                      ~f:Values.StringValuedMap.of_json
                                      parserConfiguration)
              ?updateSingleCardinalityProperties ?queueRequest
              ?dependencies:(Option.map ~f:Values.StringList.of_json
                               dependencies) ?userProvidedEdgeIds
              ?edgeOnlyLoad ~source ~format:(Values.Format_.of_json format)
              ~s3BucketRegion:(Values.S3BucketRegion.of_json s3BucketRegion)
              ~iamRoleArn ()) (Some Values.StartLoaderJobOutput.to_json)
           (Some Values.StartLoaderJobOutput.error_to_json)])
let start_m_l_data_processing_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and id = flag "id" (optional string) ~doc:"STRING String"
       and previousDataProcessingJobId =
         flag "previous-data-processing-job-id" (optional string)
           ~doc:"STRING String"
       and sagemakerIamRoleArn =
         flag "sagemaker-iam-role-arn" (optional string) ~doc:"STRING String"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and processingInstanceType =
         flag "processing-instance-type" (optional string)
           ~doc:"STRING String"
       and processingInstanceVolumeSizeInGB =
         flag "processing-instance-volume-size-in-g-b" (optional int)
           ~doc:"INT Integer"
       and processingTimeOutInSeconds =
         flag "processing-time-out-in-seconds" (optional int)
           ~doc:"INT Integer"
       and modelType =
         flag "model-type" (optional string) ~doc:"STRING String"
       and configFileName =
         flag "config-file-name" (optional string) ~doc:"STRING String"
       and subnets =
         flag "subnets" (optional json_arg) ~doc:"JSON StringList"
       and securityGroupIds =
         flag "security-group-ids" (optional json_arg) ~doc:"JSON StringList"
       and volumeEncryptionKMSKey =
         flag "volume-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String"
       and s3OutputEncryptionKMSKey =
         flag "s3-output-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String"
       and inputDataS3Location =
         flag "input-data-s3-location" (required string) ~doc:"STRING String"
       and processedDataS3Location =
         flag "processed-data-s3-location" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.start_m_l_data_processing_job
           (Values.StartMLDataProcessingJobInput.make ?id
              ?previousDataProcessingJobId ?sagemakerIamRoleArn
              ?neptuneIamRoleArn ?processingInstanceType
              ?processingInstanceVolumeSizeInGB ?processingTimeOutInSeconds
              ?modelType ?configFileName
              ?subnets:(Option.map ~f:Values.StringList.of_json subnets)
              ?securityGroupIds:(Option.map ~f:Values.StringList.of_json
                                   securityGroupIds) ?volumeEncryptionKMSKey
              ?s3OutputEncryptionKMSKey ~inputDataS3Location
              ~processedDataS3Location ())
           (Some Values.StartMLDataProcessingJobOutput.to_json)
           (Some Values.StartMLDataProcessingJobOutput.error_to_json)])
let start_m_l_model_training_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and id = flag "id" (optional string) ~doc:"STRING String"
       and previousModelTrainingJobId =
         flag "previous-model-training-job-id" (optional string)
           ~doc:"STRING String"
       and sagemakerIamRoleArn =
         flag "sagemaker-iam-role-arn" (optional string) ~doc:"STRING String"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and baseProcessingInstanceType =
         flag "base-processing-instance-type" (optional string)
           ~doc:"STRING String"
       and trainingInstanceType =
         flag "training-instance-type" (optional string) ~doc:"STRING String"
       and trainingInstanceVolumeSizeInGB =
         flag "training-instance-volume-size-in-g-b" (optional int)
           ~doc:"INT Integer"
       and trainingTimeOutInSeconds =
         flag "training-time-out-in-seconds" (optional int)
           ~doc:"INT Integer"
       and maxHPONumberOfTrainingJobs =
         flag "max-h-p-o-number-of-training-jobs" (optional int)
           ~doc:"INT Integer"
       and maxHPOParallelTrainingJobs =
         flag "max-h-p-o-parallel-training-jobs" (optional int)
           ~doc:"INT Integer"
       and subnets =
         flag "subnets" (optional json_arg) ~doc:"JSON StringList"
       and securityGroupIds =
         flag "security-group-ids" (optional json_arg) ~doc:"JSON StringList"
       and volumeEncryptionKMSKey =
         flag "volume-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String"
       and s3OutputEncryptionKMSKey =
         flag "s3-output-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String"
       and enableManagedSpotTraining =
         flag "enable-managed-spot-training" (optional bool)
           ~doc:"BOOL Boolean"
       and customModelTrainingParameters =
         flag "custom-model-training-parameters" (optional json_arg)
           ~doc:"JSON CustomModelTrainingParameters"
       and dataProcessingJobId =
         flag "data-processing-job-id" (required string) ~doc:"STRING String"
       and trainModelS3Location =
         flag "train-model-s3-location" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.start_m_l_model_training_job
           (Values.StartMLModelTrainingJobInput.make ?id
              ?previousModelTrainingJobId ?sagemakerIamRoleArn
              ?neptuneIamRoleArn ?baseProcessingInstanceType
              ?trainingInstanceType ?trainingInstanceVolumeSizeInGB
              ?trainingTimeOutInSeconds ?maxHPONumberOfTrainingJobs
              ?maxHPOParallelTrainingJobs
              ?subnets:(Option.map ~f:Values.StringList.of_json subnets)
              ?securityGroupIds:(Option.map ~f:Values.StringList.of_json
                                   securityGroupIds) ?volumeEncryptionKMSKey
              ?s3OutputEncryptionKMSKey ?enableManagedSpotTraining
              ?customModelTrainingParameters:(Option.map
                                                ~f:Values.CustomModelTrainingParameters.of_json
                                                customModelTrainingParameters)
              ~dataProcessingJobId ~trainModelS3Location ())
           (Some Values.StartMLModelTrainingJobOutput.to_json)
           (Some Values.StartMLModelTrainingJobOutput.error_to_json)])
let start_m_l_model_transform_job =
  Command.async ~summary:""
    ([%map_open.Command
       let cli_profile =
         flag "-cli-profile" (optional string) ~doc:"NAME aws profile to use"
       and cli_region =
         flag "-cli-region" (optional string) ~doc:"REGION override region"
       and endpoint_url =
         flag "-endpoint-url" (optional string)
           ~doc:"URL override endpoint url"
       and id = flag "id" (optional string) ~doc:"STRING String"
       and dataProcessingJobId =
         flag "data-processing-job-id" (optional string) ~doc:"STRING String"
       and mlModelTrainingJobId =
         flag "ml-model-training-job-id" (optional string)
           ~doc:"STRING String"
       and trainingJobName =
         flag "training-job-name" (optional string) ~doc:"STRING String"
       and sagemakerIamRoleArn =
         flag "sagemaker-iam-role-arn" (optional string) ~doc:"STRING String"
       and neptuneIamRoleArn =
         flag "neptune-iam-role-arn" (optional string) ~doc:"STRING String"
       and customModelTransformParameters =
         flag "custom-model-transform-parameters" (optional json_arg)
           ~doc:"JSON CustomModelTransformParameters"
       and baseProcessingInstanceType =
         flag "base-processing-instance-type" (optional string)
           ~doc:"STRING String"
       and baseProcessingInstanceVolumeSizeInGB =
         flag "base-processing-instance-volume-size-in-g-b" (optional int)
           ~doc:"INT Integer"
       and subnets =
         flag "subnets" (optional json_arg) ~doc:"JSON StringList"
       and securityGroupIds =
         flag "security-group-ids" (optional json_arg) ~doc:"JSON StringList"
       and volumeEncryptionKMSKey =
         flag "volume-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String"
       and s3OutputEncryptionKMSKey =
         flag "s3-output-encryption-k-m-s-key" (optional string)
           ~doc:"STRING String"
       and modelTransformOutputS3Location =
         flag "model-transform-output-s3-location" (required string)
           ~doc:"STRING String" in
       fun () ->
         call ?endpoint_url ?profile:cli_profile ?region:cli_region
           Io.start_m_l_model_transform_job
           (Values.StartMLModelTransformJobInput.make ?id
              ?dataProcessingJobId ?mlModelTrainingJobId ?trainingJobName
              ?sagemakerIamRoleArn ?neptuneIamRoleArn
              ?customModelTransformParameters:(Option.map
                                                 ~f:Values.CustomModelTransformParameters.of_json
                                                 customModelTransformParameters)
              ?baseProcessingInstanceType
              ?baseProcessingInstanceVolumeSizeInGB
              ?subnets:(Option.map ~f:Values.StringList.of_json subnets)
              ?securityGroupIds:(Option.map ~f:Values.StringList.of_json
                                   securityGroupIds) ?volumeEncryptionKMSKey
              ?s3OutputEncryptionKMSKey ~modelTransformOutputS3Location ())
           (Some Values.StartMLModelTransformJobOutput.to_json)
           (Some Values.StartMLModelTransformJobOutput.error_to_json)])
let main =
  Command.group
    ~summary:((Awso.Service.to_string Values.service) ^ " commands")
    [("cancel-gremlin-query", cancel_gremlin_query);
    ("cancel-loader-job", cancel_loader_job);
    ("cancel-m-l-data-processing-job", cancel_m_l_data_processing_job);
    ("cancel-m-l-model-training-job", cancel_m_l_model_training_job);
    ("cancel-m-l-model-transform-job", cancel_m_l_model_transform_job);
    ("cancel-open-cypher-query", cancel_open_cypher_query);
    ("create-m-l-endpoint", create_m_l_endpoint);
    ("delete-m-l-endpoint", delete_m_l_endpoint);
    ("delete-propertygraph-statistics", delete_propertygraph_statistics);
    ("delete-sparql-statistics", delete_sparql_statistics);
    ("execute-fast-reset", execute_fast_reset);
    ("execute-gremlin-explain-query", execute_gremlin_explain_query);
    ("execute-gremlin-profile-query", execute_gremlin_profile_query);
    ("execute-gremlin-query", execute_gremlin_query);
    ("execute-open-cypher-explain-query", execute_open_cypher_explain_query);
    ("execute-open-cypher-query", execute_open_cypher_query);
    ("get-engine-status", get_engine_status);
    ("get-gremlin-query-status", get_gremlin_query_status);
    ("get-loader-job-status", get_loader_job_status);
    ("get-m-l-data-processing-job", get_m_l_data_processing_job);
    ("get-m-l-endpoint", get_m_l_endpoint);
    ("get-m-l-model-training-job", get_m_l_model_training_job);
    ("get-m-l-model-transform-job", get_m_l_model_transform_job);
    ("get-open-cypher-query-status", get_open_cypher_query_status);
    ("get-propertygraph-statistics", get_propertygraph_statistics);
    ("get-propertygraph-stream", get_propertygraph_stream);
    ("get-propertygraph-summary", get_propertygraph_summary);
    ("get-r-d-f-graph-summary", get_r_d_f_graph_summary);
    ("get-sparql-statistics", get_sparql_statistics);
    ("get-sparql-stream", get_sparql_stream);
    ("list-gremlin-queries", list_gremlin_queries);
    ("list-loader-jobs", list_loader_jobs);
    ("list-m-l-data-processing-jobs", list_m_l_data_processing_jobs);
    ("list-m-l-endpoints", list_m_l_endpoints);
    ("list-m-l-model-training-jobs", list_m_l_model_training_jobs);
    ("list-m-l-model-transform-jobs", list_m_l_model_transform_jobs);
    ("list-open-cypher-queries", list_open_cypher_queries);
    ("manage-propertygraph-statistics", manage_propertygraph_statistics);
    ("manage-sparql-statistics", manage_sparql_statistics);
    ("start-loader-job", start_loader_job);
    ("start-m-l-data-processing-job", start_m_l_data_processing_job);
    ("start-m-l-model-training-job", start_m_l_model_training_job);
    ("start-m-l-model-transform-job", start_m_l_model_transform_job)]