RoutingFlyteRunner extends AbstractRoutingRunner<FlyteRunner> implements FlyteRunner { @Override public void poll(FlyteExecutionId flyteExecutionId, RunState runState) throws PollingException { runner(runState).poll(flyteExecutionId, runState); } RoutingFlyteRunner(
      FlyteRunnerFactory runnerFactory,
      Function<RunState, String> runnerId); @Override String createExecution(RunState runState, String name, FlyteExecConf flyteExecConf,
                                Map<String, String> annotations); @Override void terminateExecution(RunState runState, FlyteExecutionId flyteExecutionId); @Override void poll(FlyteExecutionId flyteExecutionId, RunState runState);  }
@Test public void testUsesCreatesRunnerOnPoll() throws FlyteRunner.PollingException { flyteRunner.poll(executionId, runState); assertThatCreateCountersContains("default"); verify(createdRunners.get("default")).poll(executionId, runState); }