FlyteAdminClient { public ExecutionOuterClass.Execution getExecution(String project, String domain, String name) { LOG.debug("getExecution {} {} {}", project, domain, name); var request = ExecutionOuterClass.WorkflowExecutionGetRequest.newBuilder() .setId( IdentifierOuterClass.WorkflowExecutionIdentifier.newBuilder() .setProject(project) .setDomain(domain) .setName(name) .build()) .build(); return stub.getExecution(request); } FlyteAdminClient(AdminServiceGrpc.AdminServiceBlockingStub stub); static FlyteAdminClient create(String target, boolean insecure); ExecutionOuterClass.ExecutionCreateResponse createExecution(
      String project,
      String domain,
      String name,
      IdentifierOuterClass.Identifier launchPlanId,
      ExecutionOuterClass.ExecutionMetadata.ExecutionMode executionMode,
      Map<String, String> annotations,
      String parameter); ExecutionOuterClass.Execution getExecution(String project, String domain, String name); ExecutionOuterClass.ExecutionTerminateResponse terminateExecution(
      String project, String domain, String name, String cause); ExecutionOuterClass.ExecutionList listExecutions(
      String project,
      String domain,
      int limit,
      String token,
      String filters); ProjectOuterClass.Projects listProjects();  }
@Test public void shouldPropagateGetExecutionToStub() { var workflowExecution = flyteAdminClient.getExecution(PROJECT, DOMAIN, EXISTING_NAME); assertThat(workflowExecution.getId().getProject(), equalTo(PROJECT)); assertThat(workflowExecution.getId().getDomain(), equalTo(DOMAIN)); assertThat(workflowExecution.getId().getName(), equalTo(EXISTING_NAME)); }