From 71f9eeaec7a80fe155d51442f17003a5f3169883 Mon Sep 17 00:00:00 2001 From: "vasary.daniel" Date: Thu, 15 Apr 2021 12:31:39 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32209 --- .../amc/user/jobengine/server/steps/ForkDownloadStep.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/server/user.jobengine.executors/amc/user/jobengine/server/steps/ForkDownloadStep.java b/server/user.jobengine.executors/amc/user/jobengine/server/steps/ForkDownloadStep.java index cc386f64..36dbddb5 100644 --- a/server/user.jobengine.executors/amc/user/jobengine/server/steps/ForkDownloadStep.java +++ b/server/user.jobengine.executors/amc/user/jobengine/server/steps/ForkDownloadStep.java @@ -32,6 +32,7 @@ public class ForkDownloadStep extends JobStep { int currentCount = 0; try { + StoreUri tempStoreUri = getManager().getStoreUri(tempStoreName, RemoteStoreProtocol.LOCAL); Path path = Paths.get(tempStoreUri.toString(true), ".STATUS"); @@ -139,6 +140,10 @@ public class ForkDownloadStep extends JobStep { //parameterek: IJobRuntime parent, String template, String name, int priority, Map parameters IJobRuntime child = getEngine().submit(null, e -> { + IJobRuntime r = (IJobRuntime) e.getSource(); + if (r.isDisableRetry()) + return; + if (e.getStatus().equals(JobStatus.CANCELED) || e.getStatus().equals(JobStatus.SUSPENDED)) EscortFiles.removeCatchedFile(escortFile); }, template, "Archiválás", priority, IJobEngine.DEFAULT_OWNER, parameters); -- 2.54.0