diff --git a/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/job/BulkRequestContainerJob.java b/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/job/BulkRequestContainerJob.java index e21abef7488..b1444ab34b2 100644 --- a/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/job/BulkRequestContainerJob.java +++ b/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/job/BulkRequestContainerJob.java @@ -379,6 +379,10 @@ class TargetTask extends ContainerTask { } void cancel() { + if (activityFuture != null) { + activityFuture.cancel(true); + } + if (target != null) { activity.cancel(target); }