Skip to content

Commit 386c40f

Browse files
committed
Revert "Review comments missed before"
This reverts commit c88eb7b.
1 parent c832f07 commit 386c40f

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

operator/src/main/java/oracle/kubernetes/operator/JobWatcher.java

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -171,15 +171,14 @@ public NextAction apply(Packet packet) {
171171
(fiber) -> {
172172
Complete complete =
173173
(V1Job job) -> {
174+
if (!shouldProcessJob(job)) {
175+
return;
176+
}
174177
completeCallbackRegistrations.remove(job.getMetadata().getName());
175178
if (didResume.compareAndSet(false, true)) {
176-
if (!shouldProcessJob(job)) {
177-
fiber.cancel(false);
178-
} else {
179-
LOGGER.fine("Job status: " + job.getStatus());
180-
packet.put(ProcessingConstants.DOMAIN_INTROSPECTOR_JOB, job);
181-
fiber.resume(packet);
182-
}
179+
LOGGER.fine("Job status: " + job.getStatus());
180+
packet.put(ProcessingConstants.DOMAIN_INTROSPECTOR_JOB, job);
181+
fiber.resume(packet);
183182
}
184183
};
185184
completeCallbackRegistrations.put(metadata.getName(), complete);

0 commit comments

Comments
 (0)