NoopFlyteRunner implements FlyteRunner { @Override public void poll(final FlyteExecutionId flyteExecutionId, final RunState runState) throws PollingException { throw new PollingException("Cannot poll for execution: " + flyteExecutionId.toUrn()); }  @Override boolean isEnabled(); @Override String createExecution(RunState runState, String name, FlyteExecConf flyteExecConf,
                                Map<String, String> annotations); @Override void terminateExecution(RunState runState, FlyteExecutionId flyteExecutionId); @Override void poll(final FlyteExecutionId flyteExecutionId, final RunState runState); @Override void close();  }
@Test public void testPollingThrowsException() { assertThrows( FlyteRunner.PollingException.class, () -> runner.poll(FLYTE_EXECUTION_ID, null) ); }