Skip to content

Commit 3d2eebe

Browse files
Minor
1 parent 64a6b2e commit 3d2eebe

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

core/src/main/java/dev/vml/es/acm/core/code/ExecutionQueue.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -140,12 +140,8 @@ public boolean isStoppingOrStopped(String executionId) {
140140
if (job == null) {
141141
return false;
142142
}
143-
ExecutionStatus status = ExecutionStatus.of(job.getProperty(ExecutionJob.ACTIVE_STATUS_PROP, String.class))
144-
.orElse(null);
145-
if (ExecutionStatus.STOPPING.equals(status)) {
146-
return true;
147-
}
148-
return Job.JobState.STOPPED.equals(job.getJobState());
143+
ExecutionStatus status = ExecutionStatus.of(job, executor);
144+
return status == ExecutionStatus.STOPPING || status == ExecutionStatus.STOPPED;
149145
}
150146

151147
public Stream<ExecutionSummary> findAllSummaries() {

0 commit comments

Comments
 (0)