@Test void testAsyncExecutionStatus() { List<AsyncExecution> asyncStepExecutions = step.getAsyncStepExecutions(context); Assertions.assertEquals(1, asyncStepExecutions.size()); Assertions.assertTrue(asyncStepExecutions.get(0) instanceof PollStageAppStatusExecution); }
@Override protected List<AsyncExecution> getAsyncStepExecutions(ProcessContext context) { return Collections.singletonList(new PollStageAppStatusExecution(recentLogsRetriever, new ApplicationStager(context))); }
StageAppStep extends TimeoutAsyncFlowableStep { @Override protected List<AsyncExecution> getAsyncStepExecutions(ProcessContext context) { return Collections.singletonList(new PollStageAppStatusExecution(recentLogsRetriever, new ApplicationStager(context))); } }
StageAppStep extends TimeoutAsyncFlowableStep { @Override protected List<AsyncExecution> getAsyncStepExecutions(ProcessContext context) { return Collections.singletonList(new PollStageAppStatusExecution(recentLogsRetriever, new ApplicationStager(context))); }  }
StageAppStep extends TimeoutAsyncFlowableStep { @Override protected List<AsyncExecution> getAsyncStepExecutions(ProcessContext context) { return Collections.singletonList(new PollStageAppStatusExecution(recentLogsRetriever, new ApplicationStager(context))); }  @Override Integer getTimeout(ProcessContext context); }
StageAppStep extends TimeoutAsyncFlowableStep { @Override protected List<AsyncExecution> getAsyncStepExecutions(ProcessContext context) { return Collections.singletonList(new PollStageAppStatusExecution(recentLogsRetriever, new ApplicationStager(context))); }  @Override Integer getTimeout(ProcessContext context);  }