FlyteAdminClient { LaunchPlanOuterClass.LaunchPlan getLaunchPlan(IdentifierOuterClass.Identifier launchPlanId) { LOG.debug("getLaunchPlan {}", launchPlanId); var request = Common.ObjectGetRequest.newBuilder() .setId(launchPlanId) .build(); return stub.getLaunchPlan(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 shouldPropagateGetLaunchPlanToStub() { var launchPlan = flyteAdminClient.getLaunchPlan(LP_IDENTIFIER); assertThat(LP_RESOURCE_TYPE, equalTo(launchPlan.getId().getResourceType())); assertThat(PROJECT, equalTo(launchPlan.getId().getProject())); assertThat(DOMAIN, equalTo(launchPlan.getId().getDomain())); assertThat(LP_NAME, equalTo(launchPlan.getId().getName())); assertThat(LP_VERSION, equalTo(launchPlan.getId().getVersion())); }