[Notes] [Git][BuildGrid/buildgrid][mablanch/157-action-browser-url] 4 co

Martin Blanchard pushed to branch mablanch/157-action-browser-url at BuildGrid / buildgrid

Commits:

9717831a

by Santiago Gil at 2019-02-13T10:56:10Z

cmd_bot and cmd_execute: allow specifying list of Platform attributes

(To address #104)

1d5f956a

by Santiago Gil at 2019-02-13T10:56:10Z

Scheduler: match OS and ISA between job and worker

With these changes the `platform` attributes of the Commands and
workers start to be considered by the scheduler.

When a given worker requests a Job, the scheduler will now try and assign it
the first job in the queue that can be executed in that worker.

As a side effect, submitting an Action with no Command now will result
in a FailedPreconditionError exception.

(This will allow to address #104)

c44ec8a6

by Martin Blanchard at 2019-02-13T11:44:11Z

Udapte .proto files to their latest version

Noteworthy changes include:
* From remote_execution.proto:
  - New message field in ExecuteResponse [1].
  - Output file and dir. parent folders clarifications [2].
  - Better doc. for do_not_cache/skip_cache_lookup [3].
  - Documention updates.
* From semver.proto:
  - Documentation updates.

[1] https://github.com/bazelbuild/remote-apis/pull/36
[2] https://github.com/bazelbuild/remote-apis/pull/42
[3] https://github.com/bazelbuild/remote-apis/pull/55

c240a7d0
by Martin Blanchard at 2019-02-13T11:44:11Z
```
Introduce an action browser URL config. key
```

17 changed files:

buildgrid/_app/commands/cmd_bot.py
buildgrid/_app/commands/cmd_cas.py
buildgrid/_app/commands/cmd_execute.py
buildgrid/_app/settings/parser.py
buildgrid/_app/settings/reference.yml
buildgrid/_protos/build/bazel/remote/execution/v2/remote_execution.proto
buildgrid/_protos/build/bazel/remote/execution/v2/remote_execution_pb2.py
buildgrid/_protos/build/bazel/remote/execution/v2/remote_execution_pb2_grpc.py
buildgrid/_protos/build/bazel/semver/semver.proto
buildgrid/server/bots/instance.py
buildgrid/server/controller.py
buildgrid/server/execution/instance.py
buildgrid/server/job.py
buildgrid/server/scheduler.py
tests/integration/bots_service.py
tests/integration/execution_service.py
tests/integration/operations_service.py

Changes:

buildgrid/_app/commands/cmd_bot.py

@@ -59,11 +59,14 @@ from ..cli import pass_context, setup_logging
                help="Time period for bot updates to the server in seconds.")
  @click.option('--parent', type=click.STRING, default=None, show_default=True,
                help="Targeted farm resource.")
 +@click.option('-w', '--worker-property', nargs=2, type=(click.STRING, click.STRING), multiple=True,
 +              help="List of key-value pairs of worker properties.")
  @click.option('-v', '--verbose', count=True,
                help='Increase log verbosity level.')
  @pass_context
 -def cli(context, parent, update_period, remote, auth_token, client_key, client_cert, server_cert,
 -        remote_cas, cas_client_key, cas_client_cert, cas_server_cert, verbose):
 +def cli(context, parent, update_period, remote, auth_token, client_key,
 +        client_cert, server_cert, remote_cas, cas_client_key, cas_client_cert,
 +        cas_server_cert, worker_property, verbose):
      setup_logging(verbosity=verbose)
      # Setup the remote execution server channel:
      try:
@@ -90,8 +93,14 @@ def cli(context, parent, update_period, remote, auth_token, client_key, client_c
      bot_interface = interface.BotInterface(context.channel)
 +    worker_properties_dict = {}
 +    for property_name, property_value in worker_property:
 +        if property_name not in worker_properties_dict:
 +            worker_properties_dict[property_name] = set()
 +        worker_properties_dict[property_name].add(property_value)
++
      worker = Worker()
 -    worker.add_device(Device())
 +    worker.add_device(Device(properties=worker_properties_dict))
      hardware_interface = HardwareInterface(worker)
      context.bot_interface = bot_interface

buildgrid/_app/commands/cmd_cas.py

@@ -65,15 +65,27 @@ def cli(context, remote, instance_name, auth_token, client_key, client_cert, ser
  @cli.command('upload-dummy', short_help="Upload a dummy action. Should be used with `execute dummy-request`")
  @pass_context
  def upload_dummy(context):
 -    action = remote_execution_pb2.Action(do_not_cache=True)
 +    command = remote_execution_pb2.Command()
 +    with upload(context.channel, instance=context.instance_name) as uploader:
 +        command_digest = uploader.put_message(command)
++
 +    if command_digest.ByteSize():
 +        click.echo('Success: Pushed Command, digest=["{}/{}]"'
 +                   .format(command_digest.hash, command_digest.size_bytes))
 +    else:
 +        click.echo("Error: Failed pushing empty Command.", err=True)
++
 +    action = remote_execution_pb2.Action(command_digest=command_digest,
 +                                         do_not_cache=True)
++
      with upload(context.channel, instance=context.instance_name) as uploader:
          action_digest = uploader.put_message(action)
      if action_digest.ByteSize():
 -        click.echo('Success: Pushed digest=["{}/{}]"'
 +        click.echo('Success: Pushed Action, digest=["{}/{}]"'
                     .format(action_digest.hash, action_digest.size_bytes))
      else:
 -        click.echo("Error: Failed pushing empty message.", err=True)
 +        click.echo("Error: Failed pushing empty Action.", err=True)
  @cli.command('upload-file', short_help="Upload files to the CAS server.")

buildgrid/_app/commands/cmd_execute.py

@@ -72,7 +72,11 @@ def cli(context, remote, instance_name, auth_token, client_key, client_cert, ser
  def request_dummy(context, number, wait_for_completion):
      click.echo("Sending execution request...")
 -    action = remote_execution_pb2.Action(do_not_cache=True)
 +    command = remote_execution_pb2.Command()
 +    command_digest = create_digest(command.SerializeToString())
++
 +    action = remote_execution_pb2.Action(command_digest=command_digest,
 +                                         do_not_cache=True)
      action_digest = create_digest(action.SerializeToString())
      stub = remote_execution_pb2_grpc.ExecutionStub(context.channel)
@@ -107,23 +111,31 @@ def request_dummy(context, number, wait_for_completion):
                help="Tuple of expected output file and is-executeable flag.")
  @click.option('--output-directory', default='testing', show_default=True,
                help="Output directory for the output files.")
 +@click.option('-p', '--platform-property', nargs=2, type=(click.STRING, click.STRING), multiple=True,
 +              help="List of key-value pairs of required platform properties.")
  @click.argument('input-root', nargs=1, type=click.Path(), required=True)
  @click.argument('commands', nargs=-1, type=click.STRING, required=True)
  @pass_context
 -def run_command(context, input_root, commands, output_file, output_directory):
 +def run_command(context, input_root, commands, output_file, output_directory,
 +                platform_property):
      stub = remote_execution_pb2_grpc.ExecutionStub(context.channel)
 -    output_executeables = []
 +    output_executables = []
      with upload(context.channel, instance=context.instance_name) as uploader:
          command = remote_execution_pb2.Command()
          for arg in commands:
              command.arguments.extend([arg])
 -        for file, is_executeable in output_file:
 +        for file, is_executable in output_file:
              command.output_files.extend([file])
 -            if is_executeable:
 -                output_executeables.append(file)
 +            if is_executable:
 +                output_executables.append(file)
++
 +        for attribute_name, attribute_value in platform_property:
 +            new_property = command.platform.properties.add()
 +            new_property.name = attribute_name
 +            new_property.value = attribute_value
          command_digest = uploader.put_message(command, queue=True)
@@ -165,6 +177,6 @@ def run_command(context, input_root, commands, output_file, output_directory):
              downloader.download_file(output_file_response.digest, path)
      for output_file_response in execute_response.result.output_files:
 -        if output_file_response.path in output_executeables:
 +        if output_file_response.path in output_executables:
              st = os.stat(path)
              os.chmod(path, st.st_mode | stat.S_IXUSR)

buildgrid/_app/settings/parser.py

@@ -235,8 +235,8 @@ class Execution(YamlFactory):
      yaml_tag = u'!execution'
 -    def __new__(cls, storage, action_cache=None):
 -        return ExecutionController(action_cache, storage)
 +    def __new__(cls, storage, action_cache=None, action_browser_url=None):
 +        return ExecutionController(storage, action_cache, action_browser_url)
  class Action(YamlFactory):

buildgrid/_app/settings/reference.yml

@@ -75,7 +75,7 @@ instances:
          # Whether or not writing to the cache is allowed.
          allow-updates: true
          ##
 -        # Whether failed actions (non-zero exit code) are stored
 +        # Whether failed actions (non-zero exit code) are stored.
          cache-failed-actions: true
        - !execution
@@ -85,6 +85,9 @@ instances:
          ##
          # Alias to an action-cache service.
          action-cache: *main-action
 +        ##
 +        # Base URL for external build action (web) browser service.
 +        action-browser-url: http://localhost:8080
        - !cas
          ##

buildgrid/_protos/build/bazel/remote/execution/v2/remote_execution.proto

@@ -81,6 +81,7 @@ service Execution {
    // action will be reported in the `status` field of the `ExecuteResponse`. The
    // server MUST NOT set the `error` field of the `Operation` proto.
    // The possible errors include:
 +  //
    // * `INVALID_ARGUMENT`: One or more arguments are invalid.
    // * `FAILED_PRECONDITION`: One or more errors occurred in setting up the
    //   action requested, such as a missing input or command or no worker being
@@ -140,6 +141,7 @@ service ActionCache {
    // Retrieve a cached execution result.
    //
    // Errors:
 +  //
    // * `NOT_FOUND`: The requested `ActionResult` is not in the cache.
    rpc GetActionResult(GetActionResultRequest) returns (ActionResult) {
      option (google.api.http) = { get: "/v2/{instance_name=**}/actionResults/{action_digest.hash}/{action_digest.size_bytes}" };
@@ -147,11 +149,6 @@ service ActionCache {
    // Upload a new execution result.
    //
 -  // This method is intended for servers which implement the distributed cache
 -  // independently of the
 -  // [Execution][build.bazel.remote.execution.v2.Execution] API. As a
 -  // result, it is OPTIONAL for servers to implement.
 -  //
    // In order to allow the server to perform access control based on the type of
    // action, and to assist with client debugging, the client MUST first upload
    // the [Action][build.bazel.remote.execution.v2.Execution] that produced the
@@ -160,7 +157,10 @@ service ActionCache {
    // `ContentAddressableStorage`.
    //
    // Errors:
 -  // * `UNIMPLEMENTED`: This method is not supported by the server.
 +  //
 +  // * `INVALID_ARGUMENT`: One or more arguments are invalid.
 +  // * `FAILED_PRECONDITION`: One or more errors occurred in updating the
 +  //   action result, such as a missing command or action.
    // * `RESOURCE_EXHAUSTED`: There is insufficient storage space to add the
    //   entry to the cache.
    rpc UpdateActionResult(UpdateActionResultRequest) returns (ActionResult) {
@@ -207,6 +207,9 @@ service ActionCache {
  // by the server. For servers which do not support multiple instances, then the
  // `instance_name` is the empty path and the leading slash is omitted, so that
  // the `resource_name` becomes `uploads/{uuid}/blobs/{hash}/{size}`.
 +// To simplify parsing, a path segment cannot equal any of the following
 +// keywords: `blobs`, `uploads`, `actions`, `actionResults`, `operations` and
 +// `capabilities`.
  //
  // When attempting an upload, if another client has already completed the upload
  // (which may occur in the middle of a single upload if another client uploads
@@ -258,10 +261,12 @@ service ContentAddressableStorage {
    // independently.
    //
    // Errors:
 +  //
    // * `INVALID_ARGUMENT`: The client attempted to upload more than the
    //   server supported limit.
    //
    // Individual requests may return the following errors, additionally:
 +  //
    // * `RESOURCE_EXHAUSTED`: There is insufficient disk quota to store the blob.
    // * `INVALID_ARGUMENT`: The
    // [Digest][build.bazel.remote.execution.v2.Digest] does not match the
@@ -284,6 +289,7 @@ service ContentAddressableStorage {
    // independently.
    //
    // Errors:
 +  //
    // * `INVALID_ARGUMENT`: The client attempted to read more than the
    //   server supported limit.
    //
@@ -390,7 +396,8 @@ message Action {
    // immediately, rather than whenever the cache entry gets evicted.
    google.protobuf.Duration timeout = 6;
 -  // If true, then the `Action`'s result cannot be cached.
 +  // If true, then the `Action`'s result cannot be cached, and in-flight
 +  // requests for the same `Action` may not be merged.
    bool do_not_cache = 7;
+ }
@@ -421,7 +428,8 @@ message Command {
    // provide its own default environment variables; these defaults can be
    // overridden using this field. Additional variables can also be specified.
    //
 -  // In order to ensure that equivalent `Command`s always hash to the same
 +  // In order to ensure that equivalent
 +  // [Command][build.bazel.remote.execution.v2.Command]s always hash to the same
    // value, the environment variables MUST be lexicographically sorted by name.
    // Sorting of strings is done by code point, equivalently, by the UTF-8 bytes.
    repeated EnvironmentVariable environment_variables = 2;
@@ -444,6 +452,9 @@ message Command {
    //
    // An output file cannot be duplicated, be a parent of another output file, or
    // have the same path as any of the listed output directories.
 +  //
 +  // Directories leading up to the output files are created by the worker prior
 +  // to execution, even if they are not explicitly part of the input root.
    repeated string output_files = 3;
    // A list of the output directories that the client expects to retrieve from
@@ -468,6 +479,10 @@ message Command {
    //
    // An output directory cannot be duplicated or have the same path as any of
    // the listed output files.
 +  //
 +  // Directories leading up to the output directories (but not the output
 +  // directories themselves) are created by the worker prior to execution, even
 +  // if they are not explicitly part of the input root.
    repeated string output_directories = 4;
    // The platform requirements for the execution environment. The server MAY
@@ -531,12 +546,18 @@ message Platform {
  // In order to ensure that two equivalent directory trees hash to the same
  // value, the following restrictions MUST be obeyed when constructing a
  // a `Directory`:
 -//   - Every child in the directory must have a path of exactly one segment.
 -//     Multiple levels of directory hierarchy may not be collapsed.
 -//   - Each child in the directory must have a unique path segment (file name).
 -//   - The files, directories and symlinks in the directory must each be sorted
 -//     in lexicographical order by path. The path strings must be sorted by code
 -//     point, equivalently, by UTF-8 bytes.
 +//
 +// * Every child in the directory must have a path of exactly one segment.
 +//   Multiple levels of directory hierarchy may not be collapsed.
 +// * Each child in the directory must have a unique path segment (file name).
 +//   Note that while the API itself is case-sensitive, the environment where
 +//   the Action is executed may or may not be case-sensitive. That is, it is
 +//   legal to call the API with a Directory that has both "Foo" and "foo" as
 +//   children, but the Action may be rejected by the remote system upon
 +//   execution.
 +// * The files, directories and symlinks in the directory must each be sorted
 +//   in lexicographical order by path. The path strings must be sorted by code
 +//   point, equivalently, by UTF-8 bytes.
  //
  // A `Directory` that obeys the restrictions is said to be in canonical form.
  //
@@ -656,11 +677,12 @@ message SymlinkNode {
  // When a `Digest` is used to refer to a proto message, it always refers to the
  // message in binary encoded form. To ensure consistent hashing, clients and
  // servers MUST ensure that they serialize messages according to the following
 -// rules, even if there are alternate valid encodings for the same message.
 -// - Fields are serialized in tag order.
 -// - There are no unknown fields.
 -// - There are no duplicate fields.
 -// - Fields are serialized according to the default semantics for their type.
 +// rules, even if there are alternate valid encodings for the same message:
 +//
 +// * Fields are serialized in tag order.
 +// * There are no unknown fields.
 +// * There are no duplicate fields.
 +// * Fields are serialized according to the default semantics for their type.
  //
  // Most protocol buffer implementations will always follow these rules when
  // serializing, but care should be taken to avoid shortcuts. For instance,
@@ -727,7 +749,7 @@ message ActionResult {
    // The output files of the action that are symbolic links to other files. Those
    // may be links to other output files, or input files, or even absolute paths
    // outside of the working directory, if the server supports
 -  // [SymlinkAbsolutePathStrategy.ALLOWED][build.bazel.remote.execution.v2.SymlinkAbsolutePathStrategy].
 +  // [SymlinkAbsolutePathStrategy.ALLOWED][build.bazel.remote.execution.v2.CacheCapabilities.SymlinkAbsolutePathStrategy].
    // For each output file requested in the `output_files` field of the Action,
    // if the corresponding file existed after
    // the action completed, a single entry will be present either in this field,
@@ -804,7 +826,7 @@ message ActionResult {
    // directories. Those may be links to other output directories, or input
    // directories, or even absolute paths outside of the working directory,
    // if the server supports
 -  // [SymlinkAbsolutePathStrategy.ALLOWED][build.bazel.remote.execution.v2.SymlinkAbsolutePathStrategy].
 +  // [SymlinkAbsolutePathStrategy.ALLOWED][build.bazel.remote.execution.v2.CacheCapabilities.SymlinkAbsolutePathStrategy].
    // For each output directory requested in the `output_directories` field of
    // the Action, if the directory file existed after
    // the action completed, a single entry will be present either in this field,
@@ -961,9 +983,19 @@ message ExecuteRequest {
    // omitted.
    string instance_name = 1;
 -  // If true, the action will be executed anew even if its result was already
 -  // present in the cache. If false, the result may be served from the
 -  // [ActionCache][build.bazel.remote.execution.v2.ActionCache].
 +  // If true, the action will be executed even if its result is already
 +  // present in the [ActionCache][build.bazel.remote.execution.v2.ActionCache].
 +  // The execution is still allowed to be merged with other in-flight executions
 +  // of the same action, however - semantically, the service MUST only guarantee
 +  // that the results of an execution with this field set were not visible
 +  // before the corresponding execution request was sent.
 +  // Note that actions from execution requests setting this field set are still
 +  // eligible to be entered into the action cache upon completion, and services
 +  // SHOULD overwrite any existing entries that may exist. This allows
 +  // skip_cache_lookup requests to be used as a mechanism for replacing action
 +  // cache entries that reference outputs no longer available or that are
 +  // poisoned in any way.
 +  // If false, the result may be served from the action cache.
    bool skip_cache_lookup = 3;
    reserved 2, 4, 5; // Used for removed fields in an earlier version of the API.
@@ -1027,6 +1059,10 @@ message ExecuteResponse {
    // phase. The keys SHOULD be human readable so that a client can display them
    // to a user.
    map<string, LogFile> server_logs = 4;
++
 +  // Freeform informational message with details on the execution of the action
 +  // that may be displayed to the user upon failure or when requested explicitly.
 +  string message = 5;
+ }
  // Metadata about an ongoing
@@ -1072,7 +1108,7 @@ message ExecuteOperationMetadata {
  // A request message for
  // [WaitExecution][build.bazel.remote.execution.v2.Execution.WaitExecution].
  message WaitExecutionRequest {
 -  // The name of the [Operation][google.longrunning.operations.v1.Operation]
 +  // The name of the [Operation][google.longrunning.Operation]
    // returned by [Execute][build.bazel.remote.execution.v2.Execution.Execute].
    string name = 1;
+ }
@@ -1193,7 +1229,7 @@ message BatchReadBlobsRequest {
  // A response message for
  // [ContentAddressableStorage.BatchReadBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.BatchReadBlobs].
  message BatchReadBlobsResponse {
 -  // A response corresponding to a single blob that the client tried to upload.
 +  // A response corresponding to a single blob that the client tried to download.
    message Response {
      // The digest to which this response corresponds.
      Digest digest = 1;
@@ -1251,7 +1287,7 @@ message GetTreeResponse {
+ }
  // A request message for
 -// [Capabilities.GetCapabilities][google.devtools.remoteexecution.v2.Capabilities.GetCapabilities].
 +// [Capabilities.GetCapabilities][build.bazel.remote.execution.v2.Capabilities.GetCapabilities].
  message GetCapabilitiesRequest {
    // The instance of the execution system to operate against. A server may
    // support multiple instances of the execution system (with their own workers,
@@ -1262,7 +1298,7 @@ message GetCapabilitiesRequest {
+ }
  // A response message for
 -// [Capabilities.GetCapabilities][google.devtools.remoteexecution.v2.Capabilities.GetCapabilities].
 +// [Capabilities.GetCapabilities][build.bazel.remote.execution.v2.Capabilities.GetCapabilities].
  message ServerCapabilities {
    // Capabilities of the remote cache system.
    CacheCapabilities cache_capabilities = 1;
@@ -1283,9 +1319,16 @@ message ServerCapabilities {
  // The digest function used for converting values into keys for CAS and Action
  // Cache.
  enum DigestFunction {
 +  // It is an error for the server to return this value.
    UNKNOWN = 0;
++
 +  // The Sha-256 digest function.
    SHA256 = 1;
++
 +  // The Sha-1 digest function.
    SHA1 = 2;
++
 +  // The MD5 digest function.
    MD5 = 3;
+ }
@@ -1312,9 +1355,10 @@ message CacheCapabilities {
    enum SymlinkAbsolutePathStrategy {
      UNKNOWN = 0;
 -    // Server will return an INVALID_ARGUMENT on input symlinks with absolute targets.
 +    // Server will return an `INVALID_ARGUMENT` on input symlinks with absolute
 +    // targets.
      // If an action tries to create an output symlink with an absolute target, a
 -    // FAILED_PRECONDITION will be returned.
 +    // `FAILED_PRECONDITION` will be returned.
      DISALLOWED = 1;
      // Server will allow symlink targets to escape the input root tree, possibly
@@ -1367,8 +1411,9 @@ message ToolDetails {
  // external context of the request. The server may use this for logging or other
  // purposes. To use it, the client attaches the header to the call using the
  // canonical proto serialization:
 -// name: build.bazel.remote.execution.v2.requestmetadata-bin
 -// contents: the base64 encoded binary RequestMetadata message.
 +//
 +// * name: `build.bazel.remote.execution.v2.requestmetadata-bin`
 +// * contents: the base64 encoded binary `RequestMetadata` message.
  message RequestMetadata {
    // The details for the tool invoking the requests.
    ToolDetails tool_details = 1;

buildgrid/_protos/build/bazel/remote/execution/v2/remote_execution_pb2.py

@@ -26,7 +26,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
    package='build.bazel.remote.execution.v2',
    syntax='proto3',
    serialized_options=_b('\n\037build.bazel.remote.execution.v2B\024RemoteExecutionProtoP\001Z\017remoteexecution\242\002\003REX\252\002\037Build.Bazel.Remote.Execution.V2'),
 -  serialized_pb=_b('\n6build/bazel/remote/execution/v2/remote_execution.proto\x12\x1f\x62uild.bazel.remote.execution.v2\x1a\x1f\x62uild/bazel/semver/semver.proto\x1a\x1cgoogle/api/annotations.proto\x1a#google/longrunning/operations.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x17google/rpc/status.proto\"\xd5\x01\n\x06\x41\x63tion\x12?\n\x0e\x63ommand_digest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x42\n\x11input_root_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12*\n\x07timeout\x18\x06 \x01(\x0b\x32\x19.google.protobuf.Duration\x12\x14\n\x0c\x64o_not_cache\x18\x07 \x01(\x08J\x04\x08\x03\x10\x06\"\xb7\x02\n\x07\x43ommand\x12\x11\n\targuments\x18\x01 \x03(\t\x12[\n\x15\x65nvironment_variables\x18\x02 \x03(\x0b\x32<.build.bazel.remote.execution.v2.Command.EnvironmentVariable\x12\x14\n\x0coutput_files\x18\x03 \x03(\t\x12\x1a\n\x12output_directories\x18\x04 \x03(\t\x12;\n\x08platform\x18\x05 \x01(\x0b\x32).build.bazel.remote.execution.v2.Platform\x12\x19\n\x11working_directory\x18\x06 \x01(\t\x1a\x32\n\x13\x45nvironmentVariable\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"{\n\x08Platform\x12\x46\n\nproperties\x18\x01 \x03(\x0b\x32\x32.build.bazel.remote.execution.v2.Platform.Property\x1a\'\n\x08Property\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"\xca\x01\n\tDirectory\x12\x38\n\x05\x66iles\x18\x01 \x03(\x0b\x32).build.bazel.remote.execution.v2.FileNode\x12\x43\n\x0b\x64irectories\x18\x02 \x03(\x0b\x32..build.bazel.remote.execution.v2.DirectoryNode\x12>\n\x08symlinks\x18\x03 \x03(\x0b\x32,.build.bazel.remote.execution.v2.SymlinkNode\"n\n\x08\x46ileNode\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x37\n\x06\x64igest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x15\n\ris_executable\x18\x04 \x01(\x08J\x04\x08\x03\x10\x04\"V\n\rDirectoryNode\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x37\n\x06\x64igest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"+\n\x0bSymlinkNode\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06target\x18\x02 \x01(\t\"*\n\x06\x44igest\x12\x0c\n\x04hash\x18\x01 \x01(\t\x12\x12\n\nsize_bytes\x18\x02 \x01(\x03\"\xec\x04\n\x16\x45xecutedActionMetadata\x12\x0e\n\x06worker\x18\x01 \x01(\t\x12\x34\n\x10queued_timestamp\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12:\n\x16worker_start_timestamp\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12>\n\x1aworker_completed_timestamp\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12?\n\x1binput_fetch_start_timestamp\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x43\n\x1finput_fetch_completed_timestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12=\n\x19\x65xecution_start_timestamp\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x41\n\x1d\x65xecution_completed_timestamp\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x41\n\x1doutput_upload_start_timestamp\x18\t \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x45\n!output_upload_completed_timestamp\x18\n \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xd6\x04\n\x0c\x41\x63tionResult\x12\x41\n\x0coutput_files\x18\x02 \x03(\x0b\x32+.build.bazel.remote.execution.v2.OutputFile\x12L\n\x14output_file_symlinks\x18\n \x03(\x0b\x32..build.bazel.remote.execution.v2.OutputSymlink\x12L\n\x12output_directories\x18\x03 \x03(\x0b\x32\x30.build.bazel.remote.execution.v2.OutputDirectory\x12Q\n\x19output_directory_symlinks\x18\x0b \x03(\x0b\x32..build.bazel.remote.execution.v2.OutputSymlink\x12\x11\n\texit_code\x18\x04 \x01(\x05\x12\x12\n\nstdout_raw\x18\x05 \x01(\x0c\x12>\n\rstdout_digest\x18\x06 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x12\n\nstderr_raw\x18\x07 \x01(\x0c\x12>\n\rstderr_digest\x18\x08 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12S\n\x12\x65xecution_metadata\x18\t \x01(\x0b\x32\x37.build.bazel.remote.execution.v2.ExecutedActionMetadataJ\x04\x08\x01\x10\x02\"p\n\nOutputFile\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x37\n\x06\x64igest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x15\n\ris_executable\x18\x04 \x01(\x08J\x04\x08\x03\x10\x04\"~\n\x04Tree\x12\x38\n\x04root\x18\x01 \x01(\x0b\x32*.build.bazel.remote.execution.v2.Directory\x12<\n\x08\x63hildren\x18\x02 \x03(\x0b\x32*.build.bazel.remote.execution.v2.Directory\"c\n\x0fOutputDirectory\x12\x0c\n\x04path\x18\x01 \x01(\t\x12<\n\x0btree_digest\x18\x03 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.DigestJ\x04\x08\x02\x10\x03\"-\n\rOutputSymlink\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x0e\n\x06target\x18\x02 \x01(\t\"#\n\x0f\x45xecutionPolicy\x12\x10\n\x08priority\x18\x01 \x01(\x05\"&\n\x12ResultsCachePolicy\x12\x10\n\x08priority\x18\x01 \x01(\x05\"\xb3\x02\n\x0e\x45xecuteRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12\x19\n\x11skip_cache_lookup\x18\x03 \x01(\x08\x12>\n\raction_digest\x18\x06 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12J\n\x10\x65xecution_policy\x18\x07 \x01(\x0b\x32\x30.build.bazel.remote.execution.v2.ExecutionPolicy\x12Q\n\x14results_cache_policy\x18\x08 \x01(\x0b\x32\x33.build.bazel.remote.execution.v2.ResultsCachePolicyJ\x04\x08\x02\x10\x03J\x04\x08\x04\x10\x05J\x04\x08\x05\x10\x06\"Z\n\x07LogFile\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x16\n\x0ehuman_readable\x18\x02 \x01(\x08\"\xbf\x02\n\x0f\x45xecuteResponse\x12=\n\x06result\x18\x01 \x01(\x0b\x32-.build.bazel.remote.execution.v2.ActionResult\x12\x15\n\rcached_result\x18\x02 \x01(\x08\x12\"\n\x06status\x18\x03 \x01(\x0b\x32\x12.google.rpc.Status\x12U\n\x0bserver_logs\x18\x04 \x03(\x0b\x32@.build.bazel.remote.execution.v2.ExecuteResponse.ServerLogsEntry\x1a[\n\x0fServerLogsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.build.bazel.remote.execution.v2.LogFile:\x02\x38\x01\"\xb3\x02\n\x18\x45xecuteOperationMetadata\x12N\n\x05stage\x18\x01 \x01(\x0e\x32?.build.bazel.remote.execution.v2.ExecuteOperationMetadata.Stage\x12>\n\raction_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x1a\n\x12stdout_stream_name\x18\x03 \x01(\t\x12\x1a\n\x12stderr_stream_name\x18\x04 \x01(\t\"O\n\x05Stage\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0f\n\x0b\x43\x41\x43HE_CHECK\x10\x01\x12\n\n\x06QUEUED\x10\x02\x12\r\n\tEXECUTING\x10\x03\x12\r\n\tCOMPLETED\x10\x04\"$\n\x14WaitExecutionRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"o\n\x16GetActionResultRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12>\n\raction_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"\x8b\x02\n\x19UpdateActionResultRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12>\n\raction_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x44\n\raction_result\x18\x03 \x01(\x0b\x32-.build.bazel.remote.execution.v2.ActionResult\x12Q\n\x14results_cache_policy\x18\x04 \x01(\x0b\x32\x33.build.bazel.remote.execution.v2.ResultsCachePolicy\"o\n\x17\x46indMissingBlobsRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12=\n\x0c\x62lob_digests\x18\x02 \x03(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"a\n\x18\x46indMissingBlobsResponse\x12\x45\n\x14missing_blob_digests\x18\x02 \x03(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"\xd6\x01\n\x17\x42\x61tchUpdateBlobsRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12R\n\x08requests\x18\x02 \x03(\x0b\x32@.build.bazel.remote.execution.v2.BatchUpdateBlobsRequest.Request\x1aP\n\x07Request\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"\xda\x01\n\x18\x42\x61tchUpdateBlobsResponse\x12U\n\tresponses\x18\x01 \x03(\x0b\x32\x42.build.bazel.remote.execution.v2.BatchUpdateBlobsResponse.Response\x1ag\n\x08Response\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\"\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.Status\"h\n\x15\x42\x61tchReadBlobsRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12\x38\n\x07\x64igests\x18\x02 \x03(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"\xe4\x01\n\x16\x42\x61tchReadBlobsResponse\x12S\n\tresponses\x18\x01 \x03(\x0b\x32@.build.bazel.remote.execution.v2.BatchReadBlobsResponse.Response\x1au\n\x08Response\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\x12\"\n\x06status\x18\x03 \x01(\x0b\x32\x12.google.rpc.Status\"\x8c\x01\n\x0eGetTreeRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12<\n\x0broot_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x11\n\tpage_size\x18\x03 \x01(\x05\x12\x12\n\npage_token\x18\x04 \x01(\t\"k\n\x0fGetTreeResponse\x12?\n\x0b\x64irectories\x18\x01 \x03(\x0b\x32*.build.bazel.remote.execution.v2.Directory\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"/\n\x16GetCapabilitiesRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\"\xe3\x02\n\x12ServerCapabilities\x12N\n\x12\x63\x61\x63he_capabilities\x18\x01 \x01(\x0b\x32\x32.build.bazel.remote.execution.v2.CacheCapabilities\x12V\n\x16\x65xecution_capabilities\x18\x02 \x01(\x0b\x32\x36.build.bazel.remote.execution.v2.ExecutionCapabilities\x12:\n\x16\x64\x65precated_api_version\x18\x03 \x01(\x0b\x32\x1a.build.bazel.semver.SemVer\x12\x33\n\x0flow_api_version\x18\x04 \x01(\x0b\x32\x1a.build.bazel.semver.SemVer\x12\x34\n\x10high_api_version\x18\x05 \x01(\x0b\x32\x1a.build.bazel.semver.SemVer\"7\n\x1d\x41\x63tionCacheUpdateCapabilities\x12\x16\n\x0eupdate_enabled\x18\x01 \x01(\x08\"\xac\x01\n\x14PriorityCapabilities\x12W\n\npriorities\x18\x01 \x03(\x0b\x32\x43.build.bazel.remote.execution.v2.PriorityCapabilities.PriorityRange\x1a;\n\rPriorityRange\x12\x14\n\x0cmin_priority\x18\x01 \x01(\x05\x12\x14\n\x0cmax_priority\x18\x02 \x01(\x05\"\x88\x04\n\x11\x43\x61\x63heCapabilities\x12H\n\x0f\x64igest_function\x18\x01 \x03(\x0e\x32/.build.bazel.remote.execution.v2.DigestFunction\x12h\n action_cache_update_capabilities\x18\x02 \x01(\x0b\x32>.build.bazel.remote.execution.v2.ActionCacheUpdateCapabilities\x12Z\n\x1b\x63\x61\x63he_priority_capabilities\x18\x03 \x01(\x0b\x32\x35.build.bazel.remote.execution.v2.PriorityCapabilities\x12\"\n\x1amax_batch_total_size_bytes\x18\x04 \x01(\x03\x12v\n\x1esymlink_absolute_path_strategy\x18\x05 \x01(\x0e\x32N.build.bazel.remote.execution.v2.CacheCapabilities.SymlinkAbsolutePathStrategy\"G\n\x1bSymlinkAbsolutePathStrategy\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0e\n\nDISALLOWED\x10\x01\x12\x0b\n\x07\x41LLOWED\x10\x02\"\xd7\x01\n\x15\x45xecutionCapabilities\x12H\n\x0f\x64igest_function\x18\x01 \x01(\x0e\x32/.build.bazel.remote.execution.v2.DigestFunction\x12\x14\n\x0c\x65xec_enabled\x18\x02 \x01(\x08\x12^\n\x1f\x65xecution_priority_capabilities\x18\x03 \x01(\x0b\x32\x35.build.bazel.remote.execution.v2.PriorityCapabilities\"6\n\x0bToolDetails\x12\x11\n\ttool_name\x18\x01 \x01(\t\x12\x14\n\x0ctool_version\x18\x02 \x01(\t\"\xa7\x01\n\x0fRequestMetadata\x12\x42\n\x0ctool_details\x18\x01 \x01(\x0b\x32,.build.bazel.remote.execution.v2.ToolDetails\x12\x11\n\taction_id\x18\x02 \x01(\t\x12\x1a\n\x12tool_invocation_id\x18\x03 \x01(\t\x12!\n\x19\x63orrelated_invocations_id\x18\x04 \x01(\t*<\n\x0e\x44igestFunction\x12\x0b\n\x07UNKNOWN\x10\x00\x12\n\n\x06SHA256\x10\x01\x12\x08\n\x04SHA1\x10\x02\x12\x07\n\x03MD5\x10\x03\x32\xb9\x02\n\tExecution\x12\x8e\x01\n\x07\x45xecute\x12/.build.bazel.remote.execution.v2.ExecuteRequest\x1a\x1d.google.longrunning.Operation\"1\x82\xd3\xe4\x93\x02+\"&/v2/{instance_name=**}/actions:execute:\x01*0\x01\x12\x9a\x01\n\rWaitExecution\x12\x35.build.bazel.remote.execution.v2.WaitExecutionRequest\x1a\x1d.google.longrunning.Operation\"1\x82\xd3\xe4\x93\x02+\"&/v2/{name=operations/**}:waitExecution:\x01*0\x01\x32\xd6\x03\n\x0b\x41\x63tionCache\x12\xd7\x01\n\x0fGetActionResult\x12\x37.build.bazel.remote.execution.v2.GetActionResultRequest\x1a-.build.bazel.remote.execution.v2.ActionResult\"\\\x82\xd3\xe4\x93\x02V\x12T/v2/{instance_name=**}/actionResults/{action_digest.hash}/{action_digest.size_bytes}\x12\xec\x01\n\x12UpdateActionResult\x12:.build.bazel.remote.execution.v2.UpdateActionResultRequest\x1a-.build.bazel.remote.execution.v2.ActionResult\"k\x82\xd3\xe4\x93\x02\x65\x1aT/v2/{instance_name=**}/actionResults/{action_digest.hash}/{action_digest.size_bytes}:\raction_result2\x9b\x06\n\x19\x43ontentAddressableStorage\x12\xbc\x01\n\x10\x46indMissingBlobs\x12\x38.build.bazel.remote.execution.v2.FindMissingBlobsRequest\x1a\x39.build.bazel.remote.execution.v2.FindMissingBlobsResponse\"3\x82\xd3\xe4\x93\x02-\"(/v2/{instance_name=**}/blobs:findMissing:\x01*\x12\xbc\x01\n\x10\x42\x61tchUpdateBlobs\x12\x38.build.bazel.remote.execution.v2.BatchUpdateBlobsRequest\x1a\x39.build.bazel.remote.execution.v2.BatchUpdateBlobsResponse\"3\x82\xd3\xe4\x93\x02-\"(/v2/{instance_name=**}/blobs:batchUpdate:\x01*\x12\xb4\x01\n\x0e\x42\x61tchReadBlobs\x12\x36.build.bazel.remote.execution.v2.BatchReadBlobsRequest\x1a\x37.build.bazel.remote.execution.v2.BatchReadBlobsResponse\"1\x82\xd3\xe4\x93\x02+\"&/v2/{instance_name=**}/blobs:batchRead:\x01*\x12\xc8\x01\n\x07GetTree\x12/.build.bazel.remote.execution.v2.GetTreeRequest\x1a\x30.build.bazel.remote.execution.v2.GetTreeResponse\"X\x82\xd3\xe4\x93\x02R\x12P/v2/{instance_name=**}/blobs/{root_digest.hash}/{root_digest.size_bytes}:getTree0\x01\x32\xbd\x01\n\x0c\x43\x61pabilities\x12\xac\x01\n\x0fGetCapabilities\x12\x37.build.bazel.remote.execution.v2.GetCapabilitiesRequest\x1a\x33.build.bazel.remote.execution.v2.ServerCapabilities\"+\x82\xd3\xe4\x93\x02%\x12#/v2/{instance_name=**}/capabilitiesBr\n\x1f\x62uild.bazel.remote.execution.v2B\x14RemoteExecutionProtoP\x01Z\x0fremoteexecution\xa2\x02\x03REX\xaa\x02\x1f\x42uild.Bazel.Remote.Execution.V2b\x06proto3')
 +  serialized_pb=_b('\n6build/bazel/remote/execution/v2/remote_execution.proto\x12\x1f\x62uild.bazel.remote.execution.v2\x1a\x1f\x62uild/bazel/semver/semver.proto\x1a\x1cgoogle/api/annotations.proto\x1a#google/longrunning/operations.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x17google/rpc/status.proto\"\xd5\x01\n\x06\x41\x63tion\x12?\n\x0e\x63ommand_digest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x42\n\x11input_root_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12*\n\x07timeout\x18\x06 \x01(\x0b\x32\x19.google.protobuf.Duration\x12\x14\n\x0c\x64o_not_cache\x18\x07 \x01(\x08J\x04\x08\x03\x10\x06\"\xb7\x02\n\x07\x43ommand\x12\x11\n\targuments\x18\x01 \x03(\t\x12[\n\x15\x65nvironment_variables\x18\x02 \x03(\x0b\x32<.build.bazel.remote.execution.v2.Command.EnvironmentVariable\x12\x14\n\x0coutput_files\x18\x03 \x03(\t\x12\x1a\n\x12output_directories\x18\x04 \x03(\t\x12;\n\x08platform\x18\x05 \x01(\x0b\x32).build.bazel.remote.execution.v2.Platform\x12\x19\n\x11working_directory\x18\x06 \x01(\t\x1a\x32\n\x13\x45nvironmentVariable\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"{\n\x08Platform\x12\x46\n\nproperties\x18\x01 \x03(\x0b\x32\x32.build.bazel.remote.execution.v2.Platform.Property\x1a\'\n\x08Property\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"\xca\x01\n\tDirectory\x12\x38\n\x05\x66iles\x18\x01 \x03(\x0b\x32).build.bazel.remote.execution.v2.FileNode\x12\x43\n\x0b\x64irectories\x18\x02 \x03(\x0b\x32..build.bazel.remote.execution.v2.DirectoryNode\x12>\n\x08symlinks\x18\x03 \x03(\x0b\x32,.build.bazel.remote.execution.v2.SymlinkNode\"n\n\x08\x46ileNode\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x37\n\x06\x64igest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x15\n\ris_executable\x18\x04 \x01(\x08J\x04\x08\x03\x10\x04\"V\n\rDirectoryNode\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x37\n\x06\x64igest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"+\n\x0bSymlinkNode\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06target\x18\x02 \x01(\t\"*\n\x06\x44igest\x12\x0c\n\x04hash\x18\x01 \x01(\t\x12\x12\n\nsize_bytes\x18\x02 \x01(\x03\"\xec\x04\n\x16\x45xecutedActionMetadata\x12\x0e\n\x06worker\x18\x01 \x01(\t\x12\x34\n\x10queued_timestamp\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12:\n\x16worker_start_timestamp\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12>\n\x1aworker_completed_timestamp\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12?\n\x1binput_fetch_start_timestamp\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x43\n\x1finput_fetch_completed_timestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12=\n\x19\x65xecution_start_timestamp\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x41\n\x1d\x65xecution_completed_timestamp\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x41\n\x1doutput_upload_start_timestamp\x18\t \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x45\n!output_upload_completed_timestamp\x18\n \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xd6\x04\n\x0c\x41\x63tionResult\x12\x41\n\x0coutput_files\x18\x02 \x03(\x0b\x32+.build.bazel.remote.execution.v2.OutputFile\x12L\n\x14output_file_symlinks\x18\n \x03(\x0b\x32..build.bazel.remote.execution.v2.OutputSymlink\x12L\n\x12output_directories\x18\x03 \x03(\x0b\x32\x30.build.bazel.remote.execution.v2.OutputDirectory\x12Q\n\x19output_directory_symlinks\x18\x0b \x03(\x0b\x32..build.bazel.remote.execution.v2.OutputSymlink\x12\x11\n\texit_code\x18\x04 \x01(\x05\x12\x12\n\nstdout_raw\x18\x05 \x01(\x0c\x12>\n\rstdout_digest\x18\x06 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x12\n\nstderr_raw\x18\x07 \x01(\x0c\x12>\n\rstderr_digest\x18\x08 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12S\n\x12\x65xecution_metadata\x18\t \x01(\x0b\x32\x37.build.bazel.remote.execution.v2.ExecutedActionMetadataJ\x04\x08\x01\x10\x02\"p\n\nOutputFile\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x37\n\x06\x64igest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x15\n\ris_executable\x18\x04 \x01(\x08J\x04\x08\x03\x10\x04\"~\n\x04Tree\x12\x38\n\x04root\x18\x01 \x01(\x0b\x32*.build.bazel.remote.execution.v2.Directory\x12<\n\x08\x63hildren\x18\x02 \x03(\x0b\x32*.build.bazel.remote.execution.v2.Directory\"c\n\x0fOutputDirectory\x12\x0c\n\x04path\x18\x01 \x01(\t\x12<\n\x0btree_digest\x18\x03 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.DigestJ\x04\x08\x02\x10\x03\"-\n\rOutputSymlink\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x0e\n\x06target\x18\x02 \x01(\t\"#\n\x0f\x45xecutionPolicy\x12\x10\n\x08priority\x18\x01 \x01(\x05\"&\n\x12ResultsCachePolicy\x12\x10\n\x08priority\x18\x01 \x01(\x05\"\xb3\x02\n\x0e\x45xecuteRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12\x19\n\x11skip_cache_lookup\x18\x03 \x01(\x08\x12>\n\raction_digest\x18\x06 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12J\n\x10\x65xecution_policy\x18\x07 \x01(\x0b\x32\x30.build.bazel.remote.execution.v2.ExecutionPolicy\x12Q\n\x14results_cache_policy\x18\x08 \x01(\x0b\x32\x33.build.bazel.remote.execution.v2.ResultsCachePolicyJ\x04\x08\x02\x10\x03J\x04\x08\x04\x10\x05J\x04\x08\x05\x10\x06\"Z\n\x07LogFile\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x16\n\x0ehuman_readable\x18\x02 \x01(\x08\"\xd0\x02\n\x0f\x45xecuteResponse\x12=\n\x06result\x18\x01 \x01(\x0b\x32-.build.bazel.remote.execution.v2.ActionResult\x12\x15\n\rcached_result\x18\x02 \x01(\x08\x12\"\n\x06status\x18\x03 \x01(\x0b\x32\x12.google.rpc.Status\x12U\n\x0bserver_logs\x18\x04 \x03(\x0b\x32@.build.bazel.remote.execution.v2.ExecuteResponse.ServerLogsEntry\x12\x0f\n\x07message\x18\x05 \x01(\t\x1a[\n\x0fServerLogsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x37\n\x05value\x18\x02 \x01(\x0b\x32(.build.bazel.remote.execution.v2.LogFile:\x02\x38\x01\"\xb3\x02\n\x18\x45xecuteOperationMetadata\x12N\n\x05stage\x18\x01 \x01(\x0e\x32?.build.bazel.remote.execution.v2.ExecuteOperationMetadata.Stage\x12>\n\raction_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x1a\n\x12stdout_stream_name\x18\x03 \x01(\t\x12\x1a\n\x12stderr_stream_name\x18\x04 \x01(\t\"O\n\x05Stage\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0f\n\x0b\x43\x41\x43HE_CHECK\x10\x01\x12\n\n\x06QUEUED\x10\x02\x12\r\n\tEXECUTING\x10\x03\x12\r\n\tCOMPLETED\x10\x04\"$\n\x14WaitExecutionRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"o\n\x16GetActionResultRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12>\n\raction_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"\x8b\x02\n\x19UpdateActionResultRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12>\n\raction_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x44\n\raction_result\x18\x03 \x01(\x0b\x32-.build.bazel.remote.execution.v2.ActionResult\x12Q\n\x14results_cache_policy\x18\x04 \x01(\x0b\x32\x33.build.bazel.remote.execution.v2.ResultsCachePolicy\"o\n\x17\x46indMissingBlobsRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12=\n\x0c\x62lob_digests\x18\x02 \x03(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"a\n\x18\x46indMissingBlobsResponse\x12\x45\n\x14missing_blob_digests\x18\x02 \x03(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"\xd6\x01\n\x17\x42\x61tchUpdateBlobsRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12R\n\x08requests\x18\x02 \x03(\x0b\x32@.build.bazel.remote.execution.v2.BatchUpdateBlobsRequest.Request\x1aP\n\x07Request\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"\xda\x01\n\x18\x42\x61tchUpdateBlobsResponse\x12U\n\tresponses\x18\x01 \x03(\x0b\x32\x42.build.bazel.remote.execution.v2.BatchUpdateBlobsResponse.Response\x1ag\n\x08Response\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\"\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.Status\"h\n\x15\x42\x61tchReadBlobsRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12\x38\n\x07\x64igests\x18\x02 \x03(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\"\xe4\x01\n\x16\x42\x61tchReadBlobsResponse\x12S\n\tresponses\x18\x01 \x03(\x0b\x32@.build.bazel.remote.execution.v2.BatchReadBlobsResponse.Response\x1au\n\x08Response\x12\x37\n\x06\x64igest\x18\x01 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\x12\"\n\x06status\x18\x03 \x01(\x0b\x32\x12.google.rpc.Status\"\x8c\x01\n\x0eGetTreeRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\x12<\n\x0broot_digest\x18\x02 \x01(\x0b\x32\'.build.bazel.remote.execution.v2.Digest\x12\x11\n\tpage_size\x18\x03 \x01(\x05\x12\x12\n\npage_token\x18\x04 \x01(\t\"k\n\x0fGetTreeResponse\x12?\n\x0b\x64irectories\x18\x01 \x03(\x0b\x32*.build.bazel.remote.execution.v2.Directory\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"/\n\x16GetCapabilitiesRequest\x12\x15\n\rinstance_name\x18\x01 \x01(\t\"\xe3\x02\n\x12ServerCapabilities\x12N\n\x12\x63\x61\x63he_capabilities\x18\x01 \x01(\x0b\x32\x32.build.bazel.remote.execution.v2.CacheCapabilities\x12V\n\x16\x65xecution_capabilities\x18\x02 \x01(\x0b\x32\x36.build.bazel.remote.execution.v2.ExecutionCapabilities\x12:\n\x16\x64\x65precated_api_version\x18\x03 \x01(\x0b\x32\x1a.build.bazel.semver.SemVer\x12\x33\n\x0flow_api_version\x18\x04 \x01(\x0b\x32\x1a.build.bazel.semver.SemVer\x12\x34\n\x10high_api_version\x18\x05 \x01(\x0b\x32\x1a.build.bazel.semver.SemVer\"7\n\x1d\x41\x63tionCacheUpdateCapabilities\x12\x16\n\x0eupdate_enabled\x18\x01 \x01(\x08\"\xac\x01\n\x14PriorityCapabilities\x12W\n\npriorities\x18\x01 \x03(\x0b\x32\x43.build.bazel.remote.execution.v2.PriorityCapabilities.PriorityRange\x1a;\n\rPriorityRange\x12\x14\n\x0cmin_priority\x18\x01 \x01(\x05\x12\x14\n\x0cmax_priority\x18\x02 \x01(\x05\"\x88\x04\n\x11\x43\x61\x63heCapabilities\x12H\n\x0f\x64igest_function\x18\x01 \x03(\x0e\x32/.build.bazel.remote.execution.v2.DigestFunction\x12h\n action_cache_update_capabilities\x18\x02 \x01(\x0b\x32>.build.bazel.remote.execution.v2.ActionCacheUpdateCapabilities\x12Z\n\x1b\x63\x61\x63he_priority_capabilities\x18\x03 \x01(\x0b\x32\x35.build.bazel.remote.execution.v2.PriorityCapabilities\x12\"\n\x1amax_batch_total_size_bytes\x18\x04 \x01(\x03\x12v\n\x1esymlink_absolute_path_strategy\x18\x05 \x01(\x0e\x32N.build.bazel.remote.execution.v2.CacheCapabilities.SymlinkAbsolutePathStrategy\"G\n\x1bSymlinkAbsolutePathStrategy\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0e\n\nDISALLOWED\x10\x01\x12\x0b\n\x07\x41LLOWED\x10\x02\"\xd7\x01\n\x15\x45xecutionCapabilities\x12H\n\x0f\x64igest_function\x18\x01 \x01(\x0e\x32/.build.bazel.remote.execution.v2.DigestFunction\x12\x14\n\x0c\x65xec_enabled\x18\x02 \x01(\x08\x12^\n\x1f\x65xecution_priority_capabilities\x18\x03 \x01(\x0b\x32\x35.build.bazel.remote.execution.v2.PriorityCapabilities\"6\n\x0bToolDetails\x12\x11\n\ttool_name\x18\x01 \x01(\t\x12\x14\n\x0ctool_version\x18\x02 \x01(\t\"\xa7\x01\n\x0fRequestMetadata\x12\x42\n\x0ctool_details\x18\x01 \x01(\x0b\x32,.build.bazel.remote.execution.v2.ToolDetails\x12\x11\n\taction_id\x18\x02 \x01(\t\x12\x1a\n\x12tool_invocation_id\x18\x03 \x01(\t\x12!\n\x19\x63orrelated_invocations_id\x18\x04 \x01(\t*<\n\x0e\x44igestFunction\x12\x0b\n\x07UNKNOWN\x10\x00\x12\n\n\x06SHA256\x10\x01\x12\x08\n\x04SHA1\x10\x02\x12\x07\n\x03MD5\x10\x03\x32\xb9\x02\n\tExecution\x12\x8e\x01\n\x07\x45xecute\x12/.build.bazel.remote.execution.v2.ExecuteRequest\x1a\x1d.google.longrunning.Operation\"1\x82\xd3\xe4\x93\x02+\"&/v2/{instance_name=**}/actions:execute:\x01*0\x01\x12\x9a\x01\n\rWaitExecution\x12\x35.build.bazel.remote.execution.v2.WaitExecutionRequest\x1a\x1d.google.longrunning.Operation\"1\x82\xd3\xe4\x93\x02+\"&/v2/{name=operations/**}:waitExecution:\x01*0\x01\x32\xd6\x03\n\x0b\x41\x63tionCache\x12\xd7\x01\n\x0fGetActionResult\x12\x37.build.bazel.remote.execution.v2.GetActionResultRequest\x1a-.build.bazel.remote.execution.v2.ActionResult\"\\\x82\xd3\xe4\x93\x02V\x12T/v2/{instance_name=**}/actionResults/{action_digest.hash}/{action_digest.size_bytes}\x12\xec\x01\n\x12UpdateActionResult\x12:.build.bazel.remote.execution.v2.UpdateActionResultRequest\x1a-.build.bazel.remote.execution.v2.ActionResult\"k\x82\xd3\xe4\x93\x02\x65\x1aT/v2/{instance_name=**}/actionResults/{action_digest.hash}/{action_digest.size_bytes}:\raction_result2\x9b\x06\n\x19\x43ontentAddressableStorage\x12\xbc\x01\n\x10\x46indMissingBlobs\x12\x38.build.bazel.remote.execution.v2.FindMissingBlobsRequest\x1a\x39.build.bazel.remote.execution.v2.FindMissingBlobsResponse\"3\x82\xd3\xe4\x93\x02-\"(/v2/{instance_name=**}/blobs:findMissing:\x01*\x12\xbc\x01\n\x10\x42\x61tchUpdateBlobs\x12\x38.build.bazel.remote.execution.v2.BatchUpdateBlobsRequest\x1a\x39.build.bazel.remote.execution.v2.BatchUpdateBlobsResponse\"3\x82\xd3\xe4\x93\x02-\"(/v2/{instance_name=**}/blobs:batchUpdate:\x01*\x12\xb4\x01\n\x0e\x42\x61tchReadBlobs\x12\x36.build.bazel.remote.execution.v2.BatchReadBlobsRequest\x1a\x37.build.bazel.remote.execution.v2.BatchReadBlobsResponse\"1\x82\xd3\xe4\x93\x02+\"&/v2/{instance_name=**}/blobs:batchRead:\x01*\x12\xc8\x01\n\x07GetTree\x12/.build.bazel.remote.execution.v2.GetTreeRequest\x1a\x30.build.bazel.remote.execution.v2.GetTreeResponse\"X\x82\xd3\xe4\x93\x02R\x12P/v2/{instance_name=**}/blobs/{root_digest.hash}/{root_digest.size_bytes}:getTree0\x01\x32\xbd\x01\n\x0c\x43\x61pabilities\x12\xac\x01\n\x0fGetCapabilities\x12\x37.build.bazel.remote.execution.v2.GetCapabilitiesRequest\x1a\x33.build.bazel.remote.execution.v2.ServerCapabilities\"+\x82\xd3\xe4\x93\x02%\x12#/v2/{instance_name=**}/capabilitiesBr\n\x1f\x62uild.bazel.remote.execution.v2B\x14RemoteExecutionProtoP\x01Z\x0fremoteexecution\xa2\x02\x03REX\xaa\x02\x1f\x42uild.Bazel.Remote.Execution.V2b\x06proto3')
+   ,
    dependencies=[build_dot_bazel_dot_semver_dot_semver__pb2.DESCRIPTOR,google_dot_api_dot_annotations__pb2.DESCRIPTOR,google_dot_longrunning_dot_operations__pb2.DESCRIPTOR,google_dot_protobuf_dot_duration__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,google_dot_rpc_dot_status__pb2.DESCRIPTOR,])
@@ -55,8 +55,8 @@ _DIGESTFUNCTION = _descriptor.EnumDescriptor(
    ],
    containing_type=None,
    serialized_options=None,
 -  serialized_start=7421,
 -  serialized_end=7481,
 +  serialized_start=7438,
 +  serialized_end=7498,
+ )
  _sym_db.RegisterEnumDescriptor(_DIGESTFUNCTION)
@@ -96,8 +96,8 @@ _EXECUTEOPERATIONMETADATA_STAGE = _descriptor.EnumDescriptor(
    ],
    containing_type=None,
    serialized_options=None,
 -  serialized_start=4074,
 -  serialized_end=4153,
 +  serialized_start=4091,
 +  serialized_end=4170,
+ )
  _sym_db.RegisterEnumDescriptor(_EXECUTEOPERATIONMETADATA_STAGE)
@@ -122,8 +122,8 @@ _CACHECAPABILITIES_SYMLINKABSOLUTEPATHSTRATEGY = _descriptor.EnumDescriptor(
    ],
    containing_type=None,
    serialized_options=None,
 -  serialized_start=6904,
 -  serialized_end=6975,
 +  serialized_start=6921,
 +  serialized_end=6992,
+ )
  _sym_db.RegisterEnumDescriptor(_CACHECAPABILITIES_SYMLINKABSOLUTEPATHSTRATEGY)
@@ -1094,8 +1094,8 @@ _EXECUTERESPONSE_SERVERLOGSENTRY = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=3752,
 -  serialized_end=3843,
 +  serialized_start=3769,
 +  serialized_end=3860,
+ )
  _EXECUTERESPONSE = _descriptor.Descriptor(
@@ -1133,6 +1133,13 @@ _EXECUTERESPONSE = _descriptor.Descriptor(
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        serialized_options=None, file=DESCRIPTOR),
 +    _descriptor.FieldDescriptor(
 +      name='message', full_name='build.bazel.remote.execution.v2.ExecuteResponse.message', index=4,
 +      number=5, type=9, cpp_type=9, label=1,
 +      has_default_value=False, default_value=_b("").decode('utf-8'),
 +      message_type=None, enum_type=None, containing_type=None,
 +      is_extension=False, extension_scope=None,
 +      serialized_options=None, file=DESCRIPTOR),
    ],
    extensions=[
    ],
@@ -1146,7 +1153,7 @@ _EXECUTERESPONSE = _descriptor.Descriptor(
    oneofs=[
    ],
    serialized_start=3524,
 -  serialized_end=3843,
 +  serialized_end=3860,
+ )
@@ -1198,8 +1205,8 @@ _EXECUTEOPERATIONMETADATA = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=3846,
 -  serialized_end=4153,
 +  serialized_start=3863,
 +  serialized_end=4170,
+ )
@@ -1229,8 +1236,8 @@ _WAITEXECUTIONREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4155,
 -  serialized_end=4191,
 +  serialized_start=4172,
 +  serialized_end=4208,
+ )
@@ -1267,8 +1274,8 @@ _GETACTIONRESULTREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4193,
 -  serialized_end=4304,
 +  serialized_start=4210,
 +  serialized_end=4321,
+ )
@@ -1319,8 +1326,8 @@ _UPDATEACTIONRESULTREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4307,
 -  serialized_end=4574,
 +  serialized_start=4324,
 +  serialized_end=4591,
+ )
@@ -1357,8 +1364,8 @@ _FINDMISSINGBLOBSREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4576,
 -  serialized_end=4687,
 +  serialized_start=4593,
 +  serialized_end=4704,
+ )
@@ -1388,8 +1395,8 @@ _FINDMISSINGBLOBSRESPONSE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4689,
 -  serialized_end=4786,
 +  serialized_start=4706,
 +  serialized_end=4803,
+ )
@@ -1426,8 +1433,8 @@ _BATCHUPDATEBLOBSREQUEST_REQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4923,
 -  serialized_end=5003,
 +  serialized_start=4940,
 +  serialized_end=5020,
+ )
  _BATCHUPDATEBLOBSREQUEST = _descriptor.Descriptor(
@@ -1463,8 +1470,8 @@ _BATCHUPDATEBLOBSREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=4789,
 -  serialized_end=5003,
 +  serialized_start=4806,
 +  serialized_end=5020,
+ )
@@ -1501,8 +1508,8 @@ _BATCHUPDATEBLOBSRESPONSE_RESPONSE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5121,
 -  serialized_end=5224,
 +  serialized_start=5138,
 +  serialized_end=5241,
+ )
  _BATCHUPDATEBLOBSRESPONSE = _descriptor.Descriptor(
@@ -1531,8 +1538,8 @@ _BATCHUPDATEBLOBSRESPONSE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5006,
 -  serialized_end=5224,
 +  serialized_start=5023,
 +  serialized_end=5241,
+ )
@@ -1569,8 +1576,8 @@ _BATCHREADBLOBSREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5226,
 -  serialized_end=5330,
 +  serialized_start=5243,
 +  serialized_end=5347,
+ )
@@ -1614,8 +1621,8 @@ _BATCHREADBLOBSRESPONSE_RESPONSE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5444,
 -  serialized_end=5561,
 +  serialized_start=5461,
 +  serialized_end=5578,
+ )
  _BATCHREADBLOBSRESPONSE = _descriptor.Descriptor(
@@ -1644,8 +1651,8 @@ _BATCHREADBLOBSRESPONSE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5333,
 -  serialized_end=5561,
 +  serialized_start=5350,
 +  serialized_end=5578,
+ )
@@ -1696,8 +1703,8 @@ _GETTREEREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5564,
 -  serialized_end=5704,
 +  serialized_start=5581,
 +  serialized_end=5721,
+ )
@@ -1734,8 +1741,8 @@ _GETTREERESPONSE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5706,
 -  serialized_end=5813,
 +  serialized_start=5723,
 +  serialized_end=5830,
+ )
@@ -1765,8 +1772,8 @@ _GETCAPABILITIESREQUEST = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5815,
 -  serialized_end=5862,
 +  serialized_start=5832,
 +  serialized_end=5879,
+ )
@@ -1824,8 +1831,8 @@ _SERVERCAPABILITIES = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=5865,
 -  serialized_end=6220,
 +  serialized_start=5882,
 +  serialized_end=6237,
+ )
@@ -1855,8 +1862,8 @@ _ACTIONCACHEUPDATECAPABILITIES = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=6222,
 -  serialized_end=6277,
 +  serialized_start=6239,
 +  serialized_end=6294,
+ )
@@ -1893,8 +1900,8 @@ _PRIORITYCAPABILITIES_PRIORITYRANGE = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=6393,
 -  serialized_end=6452,
 +  serialized_start=6410,
 +  serialized_end=6469,
+ )
  _PRIORITYCAPABILITIES = _descriptor.Descriptor(
@@ -1923,8 +1930,8 @@ _PRIORITYCAPABILITIES = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=6280,
 -  serialized_end=6452,
 +  serialized_start=6297,
 +  serialized_end=6469,
+ )
@@ -1983,8 +1990,8 @@ _CACHECAPABILITIES = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=6455,
 -  serialized_end=6975,
 +  serialized_start=6472,
 +  serialized_end=6992,
+ )
@@ -2028,8 +2035,8 @@ _EXECUTIONCAPABILITIES = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=6978,
 -  serialized_end=7193,
 +  serialized_start=6995,
 +  serialized_end=7210,
+ )
@@ -2066,8 +2073,8 @@ _TOOLDETAILS = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=7195,
 -  serialized_end=7249,
 +  serialized_start=7212,
 +  serialized_end=7266,
+ )
@@ -2118,8 +2125,8 @@ _REQUESTMETADATA = _descriptor.Descriptor(
    extension_ranges=[],
    oneofs=[
    ],
 -  serialized_start=7252,
 -  serialized_end=7419,
 +  serialized_start=7269,
 +  serialized_end=7436,
+ )
  _ACTION.fields_by_name['command_digest'].message_type = _DIGEST
@@ -2583,8 +2590,8 @@ _EXECUTION = _descriptor.ServiceDescriptor(
    file=DESCRIPTOR,
    index=0,
    serialized_options=None,
 -  serialized_start=7484,
 -  serialized_end=7797,
 +  serialized_start=7501,
 +  serialized_end=7814,
    methods=[
    _descriptor.MethodDescriptor(
      name='Execute',
@@ -2616,8 +2623,8 @@ _ACTIONCACHE = _descriptor.ServiceDescriptor(
    file=DESCRIPTOR,
    index=1,
    serialized_options=None,
 -  serialized_start=7800,
 -  serialized_end=8270,
 +  serialized_start=7817,
 +  serialized_end=8287,
    methods=[
    _descriptor.MethodDescriptor(
      name='GetActionResult',
@@ -2649,8 +2656,8 @@ _CONTENTADDRESSABLESTORAGE = _descriptor.ServiceDescriptor(
    file=DESCRIPTOR,
    index=2,
    serialized_options=None,
 -  serialized_start=8273,
 -  serialized_end=9068,
 +  serialized_start=8290,
 +  serialized_end=9085,
    methods=[
    _descriptor.MethodDescriptor(
      name='FindMissingBlobs',
@@ -2700,8 +2707,8 @@ _CAPABILITIES = _descriptor.ServiceDescriptor(
    file=DESCRIPTOR,
    index=3,
    serialized_options=None,
 -  serialized_start=9071,
 -  serialized_end=9260,
 +  serialized_start=9088,
 +  serialized_end=9277,
    methods=[
    _descriptor.MethodDescriptor(
      name='GetCapabilities',

buildgrid/_protos/build/bazel/remote/execution/v2/remote_execution_pb2_grpc.py

@@ -87,6 +87,7 @@ class ExecutionServicer(object):
      action will be reported in the `status` field of the `ExecuteResponse`. The
      server MUST NOT set the `error` field of the `Operation` proto.
      The possible errors include:
++
      * `INVALID_ARGUMENT`: One or more arguments are invalid.
      * `FAILED_PRECONDITION`: One or more errors occurred in setting up the
      action requested, such as a missing input or command or no worker being
@@ -210,6 +211,7 @@ class ActionCacheServicer(object):
      """Retrieve a cached execution result.
      Errors:
++
      * `NOT_FOUND`: The requested `ActionResult` is not in the cache.
      """
      context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -219,11 +221,6 @@ class ActionCacheServicer(object):
    def UpdateActionResult(self, request, context):
      """Upload a new execution result.
 -    This method is intended for servers which implement the distributed cache
 -    independently of the
 -    [Execution][build.bazel.remote.execution.v2.Execution] API. As a
 -    result, it is OPTIONAL for servers to implement.
+-
      In order to allow the server to perform access control based on the type of
      action, and to assist with client debugging, the client MUST first upload
      the [Action][build.bazel.remote.execution.v2.Execution] that produced the
@@ -232,7 +229,10 @@ class ActionCacheServicer(object):
      `ContentAddressableStorage`.
      Errors:
 -    * `UNIMPLEMENTED`: This method is not supported by the server.
++
 +    * `INVALID_ARGUMENT`: One or more arguments are invalid.
 +    * `FAILED_PRECONDITION`: One or more errors occurred in updating the
 +    action result, such as a missing command or action.
      * `RESOURCE_EXHAUSTED`: There is insufficient storage space to add the
      entry to the cache.
      """
@@ -299,6 +299,9 @@ class ContentAddressableStorageStub(object):
    by the server. For servers which do not support multiple instances, then the
    `instance_name` is the empty path and the leading slash is omitted, so that
    the `resource_name` becomes `uploads/{uuid}/blobs/{hash}/{size}`.
 +  To simplify parsing, a path segment cannot equal any of the following
 +  keywords: `blobs`, `uploads`, `actions`, `actionResults`, `operations` and
 +  `capabilities`.
    When attempting an upload, if another client has already completed the upload
    (which may occur in the middle of a single upload if another client uploads
@@ -395,6 +398,9 @@ class ContentAddressableStorageServicer(object):
    by the server. For servers which do not support multiple instances, then the
    `instance_name` is the empty path and the leading slash is omitted, so that
    the `resource_name` becomes `uploads/{uuid}/blobs/{hash}/{size}`.
 +  To simplify parsing, a path segment cannot equal any of the following
 +  keywords: `blobs`, `uploads`, `actions`, `actionResults`, `operations` and
 +  `capabilities`.
    When attempting an upload, if another client has already completed the upload
    (which may occur in the middle of a single upload if another client uploads
@@ -450,10 +456,12 @@ class ContentAddressableStorageServicer(object):
      independently.
      Errors:
++
      * `INVALID_ARGUMENT`: The client attempted to upload more than the
      server supported limit.
      Individual requests may return the following errors, additionally:
++
      * `RESOURCE_EXHAUSTED`: There is insufficient disk quota to store the blob.
      * `INVALID_ARGUMENT`: The
      [Digest][build.bazel.remote.execution.v2.Digest] does not match the
@@ -478,6 +486,7 @@ class ContentAddressableStorageServicer(object):
      independently.
      Errors:
++
      * `INVALID_ARGUMENT`: The client attempted to read more than the
      server supported limit.

buildgrid/_protos/build/bazel/semver/semver.proto

@@ -23,9 +23,19 @@ option java_outer_classname = "SemverProto";
  option java_package = "build.bazel.semver";
  option objc_class_prefix = "SMV";
 +// The full version of a given tool.
  message SemVer {
 +  // The major version, e.g 10 for 10.2.3.
    int32 major = 1;
++
 +  // The minor version, e.g. 2 for 10.2.3.
    int32 minor = 2;
++
 +  // The patch version, e.g 3 for 10.2.3.
    int32 patch = 3;
++
 +  // The pre-release version. Either this field or major/minor/patch fields
 +  // must be filled. They are mutually exclusive. Pre-release versions are
 +  // assumed to be earlier than any released versions.
    string prerelease = 4;
+ }

buildgrid/server/bots/instance.py

@@ -50,7 +50,6 @@ class BotsInterface:
          register with the service, the old one should be closed along
          with all its jobs.
          """
+-
          bot_id = bot_session.bot_id
          if bot_id == "":
@@ -100,10 +99,25 @@ class BotsInterface:
          return bot_session
      def _request_leases(self, bot_session):
 -        # TODO: Send worker capabilities to the scheduler!
          # Only send one lease at a time currently.
          if not bot_session.leases:
 -            leases = self._scheduler.request_job_leases({})
 +            worker_capabilities = {}
++
 +            # TODO? Fail if there are no devices in the worker?
 +            if bot_session.worker.devices:
 +                # According to the spec:
 +                #   "The first device in the worker is the "primary device" -
 +                #   that is, the device running a bot and which is
 +                #   responsible for actually executing commands."
 +                primary_device = bot_session.worker.devices[0]
++
 +                for device_property in primary_device.properties:
 +                    if device_property.key not in worker_capabilities:
 +                        worker_capabilities[device_property.key] = set()
 +                    worker_capabilities[device_property.key].add(device_property.value)
++
 +            leases = self._scheduler.request_job_leases(worker_capabilities)
++
              if leases:
                  for lease in leases:
                      self._assigned_leases[bot_session.name].add(lease.id)

buildgrid/server/controller.py

@@ -36,7 +36,7 @@ from .operations.instance import OperationsInstance
  class ExecutionController:
 -    def __init__(self, action_cache=None, storage=None):
 +    def __init__(self, storage=None, action_cache=None, action_browser_url=None):
          self.__logger = logging.getLogger(__name__)
          scheduler = Scheduler(action_cache)

buildgrid/server/execution/instance.py

@@ -22,7 +22,7 @@ An instance of the Remote Execution Service.
  import logging
  from buildgrid._exceptions import FailedPreconditionError, InvalidArgumentError, NotFoundError
 -from buildgrid._protos.build.bazel.remote.execution.v2.remote_execution_pb2 import Action
 +from buildgrid._protos.build.bazel.remote.execution.v2.remote_execution_pb2 import Action, Command
  from buildgrid.utils import get_hash_type
@@ -50,11 +50,22 @@ class ExecutionInstance:
          this action.
          """
          action = self._storage.get_message(action_digest, Action)
+-
          if not action:
              raise FailedPreconditionError("Could not get action from storage.")
 +        command = self._storage.get_message(action.command_digest, Command)
++
 +        if not command:
 +            raise FailedPreconditionError("Could not get command from storage.")
++
 +        platform_requirements = {}
 +        for platform_property in command.platform.properties:
 +            if platform_property.name not in platform_requirements:
 +                platform_requirements[platform_property.name] = set()
 +            platform_requirements[platform_property.name].add(platform_property.value)
++
          return self._scheduler.queue_job_action(action, action_digest,
 +                                                platform_requirements=platform_requirements,
                                                  skip_cache_lookup=skip_cache_lookup)
      def register_job_peer(self, job_name, peer, message_queue):

buildgrid/server/job.py

@@ -29,7 +29,7 @@ from buildgrid._protos.google.rpc import code_pb2
  class Job:
 -    def __init__(self, action, action_digest, priority=0):
 +    def __init__(self, action, action_digest, platform_requirements=None, priority=0):
          self.__logger = logging.getLogger(__name__)
          self._name = str(uuid.uuid4())
@@ -59,6 +59,9 @@ class Job:
          self._do_not_cache = self._action.do_not_cache
          self._n_tries = 0
 +        self._platform_requirements = platform_requirements \
 +            if platform_requirements else dict()
++
          self._done = False
      def __lt__(self, other):
@@ -113,6 +116,10 @@ class Job:
      # --- Public API: REAPI ---
 +    @property
 +    def platform_requirements(self):
 +        return self._platform_requirements
++
      @property
      def do_not_cache(self):
          return self._do_not_cache

buildgrid/server/scheduler.py

@@ -145,7 +145,8 @@ class Scheduler:
          if not job.n_peers and job.done and not job.lease:
              self._delete_job(job.name)
 -    def queue_job_action(self, action, action_digest, priority=0, skip_cache_lookup=False):
 +    def queue_job_action(self, action, action_digest, platform_requirements=None,
 +                         priority=0, skip_cache_lookup=False):
          """Inserts a newly created job into the execution queue.
          Warning:
@@ -155,6 +156,9 @@ class Scheduler:
          Args:
              action (Action): the given action to queue for execution.
              action_digest (Digest): the digest of the given action.
 +            platform_requirements (dict(set)): platform attributes that a worker
 +                must satisfy in order to be assigned the job. (Each key can
 +                have multiple values.)
              priority (int): the execution job's priority.
              skip_cache_lookup (bool): whether or not to look for pre-computed
                  result for the given action.
@@ -178,7 +182,9 @@ class Scheduler:
                  return job.name
 -        job = Job(action, action_digest, priority=priority)
 +        job = Job(action, action_digest,
 +                  platform_requirements=platform_requirements,
 +                  priority=priority)
          self.__logger.debug("Job created for action [%s]: [%s]",
                              action_digest.hash[:8], job.name)
@@ -271,28 +277,29 @@ class Scheduler:
          """Generates a list of the highest priority leases to be run.
          Args:
 -            worker_capabilities (dict): a set of key-value pairs decribing the
 +            worker_capabilities (dict): a set of key-value pairs describing the
                  worker properties, configuration and state at the time of the
                  request.
+-
 -        Warning: Worker capabilities handling is not implemented at the moment!
          """
          if not self.__queue:
              return []
 -        # TODO: Try to match worker_capabilities with jobs properties.
 -        job = self.__queue.pop()
 +        # Looking for the first job that could be assigned to the worker...
 +        for job_index, job in enumerate(self.__queue):
 +            if self._worker_is_capable(worker_capabilities, job):
 +                self.__logger.info("Job scheduled to run: [%s]", job.name)
 -        self.__logger.info("Job scheduled to run: [%s]", job.name)
 +                lease = job.lease
 -        lease = job.lease
 +                if not lease:
 +                    # For now, one lease at a time:
 +                    lease = job.create_lease()
 -        if not lease:
 -            # For now, one lease at a time:
 -            lease = job.create_lease()
 +                if lease:
 +                    del self.__queue[job_index]
 +                    return [lease]
 -        if lease:
 -            return [lease]
 +                return None
          return None
@@ -622,3 +629,28 @@ class Scheduler:
                      for message_queue in self.__build_metadata_queues:
                          message_queue.put(message)
++
 +    def _worker_is_capable(self, worker_capabilities, job):
 +        """Returns whether the worker is suitable to run the job."""
 +        # TODO: Replace this with the logic defined in the Platform msg. standard.
++
 +        job_requirements = job.platform_requirements
 +        # For now we'll only check OS and ISA properties.
++
 +        if not job_requirements:
 +            return True
++
 +        # OS:
 +        worker_oses = worker_capabilities.get('os', set())
 +        job_oses = job_requirements.get('os', set())
 +        if job_oses and not (job_oses & worker_oses):
 +            return False
++
 +        # ISAs:
 +        worker_isas = worker_capabilities.get('isa', [])
 +        job_isas = job_requirements.get('isa', None)
++
 +        if job_isas and not (job_isas & worker_isas):
 +            return False
++
 +        return True

tests/integration/bots_service.py

@@ -153,11 +153,27 @@ def test_post_bot_event_temp(context, instance):
      context.set_code.assert_called_once_with(grpc.StatusCode.UNIMPLEMENTED)
 -def _inject_work(scheduler, action=None, action_digest=None):
 +def test_unmet_platform_requirements(bot_session, context, instance):
 +    request = bots_pb2.CreateBotSessionRequest(parent='',
 +                                               bot_session=bot_session)
++
 +    action_digest = remote_execution_pb2.Digest(hash='gaff')
 +    _inject_work(instance._instances[""]._scheduler,
 +                 action_digest=action_digest,
 +                 platform_requirements={'os': set('wonderful-os')})
++
 +    response = instance.CreateBotSession(request, context)
++
 +    assert len(response.leases) == 0
++
++
 +def _inject_work(scheduler, action=None, action_digest=None,
 +                 platform_requirements=None):
      if not action:
          action = remote_execution_pb2.Action()
      if not action_digest:
          action_digest = remote_execution_pb2.Digest()
 -    scheduler.queue_job_action(action, action_digest, skip_cache_lookup=True)
 +    scheduler.queue_job_action(action, action_digest, platform_requirements,
 +                               skip_cache_lookup=True)

tests/integration/execution_service.py

@@ -37,7 +37,12 @@ from buildgrid.server.execution.service import ExecutionService
  server = mock.create_autospec(grpc.server)
 -action = remote_execution_pb2.Action(do_not_cache=True)
++
 +command = remote_execution_pb2.Command()
 +command_digest = create_digest(command.SerializeToString())
++
 +action = remote_execution_pb2.Action(command_digest=command_digest,
 +                                     do_not_cache=True)
  action_digest = create_digest(action.SerializeToString())
@@ -50,15 +55,21 @@ def context():
  @pytest.fixture(params=["action-cache", "no-action-cache"])
  def controller(request):
      storage = lru_memory_cache.LRUMemoryCache(1024 * 1024)
++
 +    write_session = storage.begin_write(command_digest)
 +    write_session.write(command.SerializeToString())
 +    storage.commit_write(command_digest, write_session)
++
      write_session = storage.begin_write(action_digest)
 +    write_session.write(action.SerializeToString())
      storage.commit_write(action_digest, write_session)
      if request.param == "action-cache":
          cache = ActionCache(storage, 50)
 -        yield ExecutionController(cache, storage)
 +        yield ExecutionController(storage=storage, action_cache=cache)
      else:
 -        yield ExecutionController(None, storage)
 +        yield ExecutionController(storage=storage)
  # Instance to test

tests/integration/operations_service.py

@@ -36,7 +36,12 @@ from buildgrid.utils import create_digest
  server = mock.create_autospec(grpc.server)
  instance_name = "blade"
 -action = remote_execution_pb2.Action(do_not_cache=True)
++
 +command = remote_execution_pb2.Command()
 +command_digest = create_digest(command.SerializeToString())
++
 +action = remote_execution_pb2.Action(command_digest=command_digest,
 +                                     do_not_cache=True)
  action_digest = create_digest(action.SerializeToString())
@@ -57,10 +62,16 @@ def execute_request():
  @pytest.fixture
  def controller():
      storage = lru_memory_cache.LRUMemoryCache(1024 * 1024)
++
 +    write_session = storage.begin_write(command_digest)
 +    write_session.write(command.SerializeToString())
 +    storage.commit_write(command_digest, write_session)
++
      write_session = storage.begin_write(action_digest)
 +    write_session.write(action.SerializeToString())
      storage.commit_write(action_digest, write_session)
 -    yield ExecutionController(None, storage)
 +    yield ExecutionController(storage=storage)
  # Instance to test

[Notes] [Git][BuildGrid/buildgrid][mablanch/157-action-browser-url] 4 commits: cmd_bot and cmd_execute: allow specifying list of Platform attributes

Martin Blanchard pushed to branch mablanch/157-action-browser-url at BuildGrid / buildgrid

Commits:

17 changed files:

Changes: