本文整理了Java中com.netflix.spinnaker.orca.pipeline.model.Stage.getTasks()
方法的一些代码示例,展示了Stage.getTasks()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Stage.getTasks()
方法的具体详情如下:
包路径:com.netflix.spinnaker.orca.pipeline.model.Stage
类名称:Stage
方法名:getTasks
暂无
代码示例来源:origin: com.netflix.spinnaker.orca/orca-core
private void onTaskStarted(TaskStarted event) {
Execution execution = retrieve(event);
List<Stage> stages = execution.getStages();
stages
.stream()
.filter(it -> it.getId().equals(event.getStageId()))
.findFirst()
.ifPresent(stage ->
delegate.beforeTask(
persister,
stage,
stage.getTasks().stream().filter(it -> it.getId().equals(event.getTaskId())).findFirst().get()
)
);
}
代码示例来源:origin: com.netflix.spinnaker.orca/orca-core
private void onTaskComplete(TaskComplete event) {
Execution execution = retrieve(event);
List<Stage> stages = execution.getStages();
ExecutionStatus status = event.getStatus();
stages
.stream()
.filter(it -> it.getId().equals(event.getStageId()))
.findFirst()
.ifPresent(stage ->
delegate.afterTask(persister,
stage,
stage.getTasks().stream().filter(it -> it.getId().equals(event.getTaskId())).findFirst().get(),
status,
// TODO: not sure if status.isSuccessful covers all the weird cases here
status.isSuccessful()
)
);
}
代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis
map.put(prefix + "context", mapper.writeValueAsString(stage.getContext()));
map.put(prefix + "outputs", mapper.writeValueAsString(stage.getOutputs()));
map.put(prefix + "tasks", mapper.writeValueAsString(stage.getTasks()));
map.put(prefix + "lastModified", (stage.getLastModified() != null ? mapper.writeValueAsString(stage.getLastModified()) : null));
} catch (JsonProcessingException e) {
内容来源于网络,如有侵权,请联系作者删除!