git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...

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 cc386f64949a9f44f63a880478e852c38268a88a..36dbddb5df53e5bd60284f392eb35c5075a71386 100644 (file)
--- 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;\r
 \r
                try {\r
+\r
                        StoreUri tempStoreUri = getManager().getStoreUri(tempStoreName, RemoteStoreProtocol.LOCAL);\r
                        Path path = Paths.get(tempStoreUri.toString(true), ".STATUS");\r
 \r
@@ -139,6 +140,10 @@ public class ForkDownloadStep extends JobStep {
 \r
                        //parameterek: IJobRuntime parent, String template, String name, int priority, Map<String, Object> parameters\r
                        IJobRuntime child = getEngine().submit(null, e -> {\r
+                               IJobRuntime r = (IJobRuntime) e.getSource();\r
+                               if (r.isDisableRetry())\r
+                                       return;\r
+\r
                                if (e.getStatus().equals(JobStatus.CANCELED) || e.getStatus().equals(JobStatus.SUSPENDED))\r
                                        EscortFiles.removeCatchedFile(escortFile);\r
                        }, template, "Archiválás", priority, IJobEngine.DEFAULT_OWNER, parameters);\r