src/main/java/build/buildfarm/instance/shard/ShardInstance.java [2431:2478]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    if (operation.getMetadata().is(QueuedOperationMetadata.class)) {
      operation =
          operation
              .toBuilder()
              .setMetadata(Any.pack(expectExecuteOperationMetadata(operation)))
              .build();
    }
    return operation;
  }

  @Override
  protected Logger getLogger() {
    return logger;
  }

  @Override
  public GetClientStartTimeResult getClientStartTime(GetClientStartTimeRequest request) {
    try {
      return backplane.getClientStartTime(request);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
    }
  }

  @Override
  public CasIndexResults reindexCas(String hostName) {
    try {
      return backplane.reindexCas(hostName);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
    }
  }

  @Override
  public FindOperationsResults findOperations(String filterPredicate) {
    try {
      return backplane.findOperations(this, filterPredicate);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
    }
  }

  @Override
  public void deregisterWorker(String workerName) {
    try {
      backplane.deregisterWorker(workerName);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/build/buildfarm/worker/shard/ShardWorkerInstance.java [350:397]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    if (operation.getMetadata().is(QueuedOperationMetadata.class)) {
      operation =
          operation
              .toBuilder()
              .setMetadata(Any.pack(expectExecuteOperationMetadata(operation)))
              .build();
    }
    return operation;
  }

  @Override
  protected Logger getLogger() {
    return logger;
  }

  @Override
  public GetClientStartTimeResult getClientStartTime(GetClientStartTimeRequest request) {
    try {
      return backplane.getClientStartTime(request);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
    }
  }

  @Override
  public CasIndexResults reindexCas(String hostName) {
    try {
      return backplane.reindexCas(hostName);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
    }
  }

  @Override
  public FindOperationsResults findOperations(String filterPredicate) {
    try {
      return backplane.findOperations(this, filterPredicate);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
    }
  }

  @Override
  public void deregisterWorker(String workerName) {
    try {
      backplane.deregisterWorker(workerName);
    } catch (IOException e) {
      throw Status.fromThrowable(e).asRuntimeException();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -