Send a batchOptimizeTours Request

import com.google.api.gax.longrunning.OperationFuture;
import com.google.cloud.optimization.v1.AsyncModelMetadata;
import com.google.cloud.optimization.v1.BatchOptimizeToursRequest;
import com.google.cloud.optimization.v1.BatchOptimizeToursRequest.AsyncModelConfig;
import com.google.cloud.optimization.v1.BatchOptimizeToursResponse;
import com.google.cloud.optimization.v1.DataFormat;
import com.google.cloud.optimization.v1.FleetRoutingClient;
import com.google.cloud.optimization.v1.GcsDestination;
import com.google.cloud.optimization.v1.GcsSource;
import com.google.cloud.optimization.v1.InputConfig;
import com.google.cloud.optimization.v1.OutputConfig;

/**
 * This is an example to send a request to Cloud Fleet Routing asynchronous API via Java API Client.
 * A sample async_request_java.textproto file and a sample request_model_java.json file can be found
 * in the resources folder.
 */
public class AsyncApi {
  public static void callAsyncApi() throws Exception {
    // TODO(developer): Replace these variables before running the sample.
    String projectParent = "projects/{YOUR_GCP_PROJECT_ID}";
    String inputUri = "gs://YOUR_GCS_PATH";
    String outputUri = "gs://YOUR_SOLUTION_PATH";
    callAsyncApi(projectParent, inputUri, outputUri);
  }

  public static void callAsyncApi(String projectParent, String inputUri, String outputUri)
      throws Exception {
    GcsSource gcsSource = GcsSource.newBuilder().setUri(inputUri).build();
    InputConfig inputConfig =
        InputConfig.newBuilder().setGcsSource(gcsSource).setDataFormat(DataFormat.JSON).build();
    GcsDestination gcsDestination = GcsDestination.newBuilder().setUri(outputUri).build();
    OutputConfig outputConfig =
        OutputConfig.newBuilder()
            .setGcsDestination(gcsDestination)
            .setDataFormat(DataFormat.JSON)
            .build();

    AsyncModelConfig asyncModelConfig =
        AsyncModelConfig.newBuilder()
            .setInputConfig(inputConfig)
            .setOutputConfig(outputConfig)
            .build();
    BatchOptimizeToursRequest request =
        BatchOptimizeToursRequest.newBuilder()
            .setParent(projectParent)
            .addModelConfigs(asyncModelConfig)
            .build();

    FleetRoutingClient fleetRoutingClient = FleetRoutingClient.create();
    OperationFuture<BatchOptimizeToursResponse, AsyncModelMetadata> response =
        fleetRoutingClient.batchOptimizeToursAsync(request);
    System.out.format("the response name: %s\n", response.getInitialFuture().get().getName());

    // Block to wait for the job to finish.
    response.getPollingFuture().get();
    if (response.getMetadata().get().getState() == AsyncModelMetadata.State.SUCCEEDED) {
      // Code to do your stuff
      System.out.println("Job finished successfully.");
    } else {
      System.out.println(
          "Job failed with message:" + response.getPollingFuture().get().getErrorMessage());
    }
  }
}

from google.api_core.exceptions import GoogleAPICallError
from google.cloud import optimization_v1

# TODO(developer): Uncomment these variables before running the sample.
# project_id= 'YOUR_PROJECT_ID'
# request_file_name = 'YOUR_REQUEST_FILE_NAME'
# request_model_gcs_path = 'gs://YOUR_PROJECT/YOUR_BUCKET/YOUR_REQUEST_MODEL_PATH'
# model_solution_gcs_path = 'gs://YOUR_PROJECT/YOUR_BUCKET/YOUR_SOLUCTION_PATH'


def call_async_api(
    project_id: str, request_model_gcs_path: str, model_solution_gcs_path_prefix: str
) -> None:
    """Call the async api for fleet routing."""
    # Use the default credentials for the environment to authenticate the client.
    fleet_routing_client = optimization_v1.FleetRoutingClient()
    request_file_name = "resources/async_request.json"

    with open(request_file_name) as f:
        fleet_routing_request = optimization_v1.BatchOptimizeToursRequest.from_json(
            f.read()
        )
        fleet_routing_request.parent = f"projects/{project_id}"
        for idx, mc in enumerate(fleet_routing_request.model_configs):
            mc.input_config.gcs_source.uri = request_model_gcs_path
            model_solution_gcs_path = f"{model_solution_gcs_path_prefix}_{idx}"
            mc.output_config.gcs_destination.uri = model_solution_gcs_path

        # The timeout argument for the gRPC call is independent from the `timeout`
        # field in the request's OptimizeToursRequest message(s).
        operation = fleet_routing_client.batch_optimize_tours(fleet_routing_request)
        print(operation.operation.name)

        try:
            # Block to wait for the job to finish.
            result = operation.result()
            print(result)
            # Do you stuff.
        except GoogleAPICallError:
            print(operation.operation.error)

import com.google.cloud.optimization.v1.FleetRoutingClient;
import com.google.longrunning.Operation;
import java.io.IOException;

class GetOperation {

  static void getOperation() throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    String operationFullId = "projects/[projectId]/operations/[operationId]";
    getOperation(operationFullId);
  }

  // Get the status of an operation
  static void getOperation(String operationFullId) throws IOException {
    // Initialize client that will be used to send requests. This client only needs to be created
    // once, and can be reused for multiple requests. After completing all of your requests, call
    // the "close" method on the client to safely clean up any remaining background resources.
    try (FleetRoutingClient client = FleetRoutingClient.create()) {
      // Get the latest state of a long-running operation.
      Operation operation = client.getOperationsClient().getOperation(operationFullId);

      // Display operation details.
      System.out.println("Operation details:");
      System.out.format("\tName: %s\n", operation.getName());
      System.out.format("\tMetadata Type Url: %s\n", operation.getMetadata().getTypeUrl());
      System.out.format("\tDone: %s\n", operation.getDone());
      if (operation.hasResponse()) {
        System.out.format("\tResponse Type Url: %s\n", operation.getResponse().getTypeUrl());
      }
      if (operation.hasError()) {
        System.out.println("\tResponse:");
        System.out.format("\t\tError code: %s\n", operation.getError().getCode());
        System.out.format("\t\tError message: %s\n", operation.getError().getMessage());
      }
    }
  }
}

from google.cloud import optimization_v1


def get_operation(operation_full_id: str) -> None:
    """Get operation details and status."""
    # TODO(developer): Uncomment and set the following variables
    # operation_full_id = \
    #     "projects/[projectId]/operations/[operationId]"

    client = optimization_v1.FleetRoutingClient()
    # Get the latest state of a long-running operation.
    response = client.transport.operations_client.get_operation(operation_full_id)

    print(f"Name: {response.name}")
    print("Operation details:")
    print(response)