diff --git a/tasks/aws/src/main/java/com/walmartlabs/concord/plugins/aws/EcrTask.java b/tasks/aws/src/main/java/com/walmartlabs/concord/plugins/aws/EcrTask.java
index 46a647c5..b17dc082 100644
--- a/tasks/aws/src/main/java/com/walmartlabs/concord/plugins/aws/EcrTask.java
+++ b/tasks/aws/src/main/java/com/walmartlabs/concord/plugins/aws/EcrTask.java
@@ -31,11 +31,12 @@
 import org.slf4j.LoggerFactory;
 import software.amazon.awssdk.regions.Region;
 import software.amazon.awssdk.services.ecr.EcrClient;
-import software.amazon.awssdk.services.ecr.model.DescribeImagesRequest;
-import software.amazon.awssdk.services.ecr.model.ImageDetail;
+import software.amazon.awssdk.services.ecr.model.*;
 
 import javax.inject.Inject;
 import javax.inject.Named;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 
 import static java.util.Objects.requireNonNull;
@@ -62,6 +63,8 @@ public TaskResult execute(Variables input) {
         var action = input.assertString("action");
         if ("describe-images".equals(action)) {
             return describeImages(input);
+        } if ("delete-images".equals(action)) {
+            return deleteImage(input);
         }
         throw new IllegalArgumentException("Unsupported action: " + action);
     }
@@ -103,8 +106,90 @@ private TaskResult describeImages(Variables input) {
         }
     }
 
+
+    private TaskResult deleteImage(Variables input) {
+        var region = assertRegion(input, "region");
+        var repositoryName = input.assertString("repositoryName");
+        var imageIds = assertImageIds(input);
+        var debug = input.getBoolean("debug", context.processConfiguration().debug());
+
+        try (var client = EcrClient.builder()
+                .region(region)
+                .build()) {
+
+            List<ImageFailure> failures = new ArrayList<>();
+            for (var ids : partitions(imageIds, 100)) {
+                var request = BatchDeleteImageRequest.builder()
+                        .repositoryName(repositoryName)
+                        .imageIds(ids)
+                        .build();
+
+                var response = client.batchDeleteImage(request);
+                if (response.hasFailures()) {
+                    failures.addAll(response.failures());
+                }
+
+                if (debug) {
+                    log.info("Processed {}/{}, failures: {}", ids.size(), imageIds.size(), failures.size());
+                }
+            }
+
+            if (!failures.isEmpty()) {
+                return TaskResult.fail("Failures in response")
+                        .values(Map.of("failures", serialize(failures)));
+            }
+
+            return TaskResult.success();
+        }
+    }
+
+    private static List<Map<String, Object>> serialize(List<ImageFailure> failures) {
+        List<Map<String, Object>> result = new ArrayList<>();
+        for (var failure : failures) {
+            result.add(Map.of("imageId", serialize(failure.imageId()),
+                    "failureCode", failure.failureCode(),
+                    "failureReason", failure.failureReason()));
+        }
+
+        return result;
+    }
+
+    private static String serialize(ImageIdentifier imageIdentifier) {
+        if (imageIdentifier == null) {
+            return null;
+        }
+        if (imageIdentifier.imageTag() != null) {
+            return imageIdentifier.imageTag();
+        }
+        return imageIdentifier.imageDigest();
+    }
+
     private static Region assertRegion(Variables input, String key) {
         String region = input.assertString(key);
         return Region.of(region);
     }
+
+    private static List<ImageIdentifier> assertImageIds(Variables input) {
+        String imageTag = input.getString("imageTag");
+        if (imageTag != null) {
+            return List.of(ImageIdentifier.builder().imageTag(imageTag).build());
+        }
+
+        List<String> imageTags = input.getList("imageTags", List.of());
+        if (!imageTags.isEmpty()) {
+            return imageTags.stream().map(i -> ImageIdentifier.builder().imageTag(i).build()).toList();
+        }
+
+        throw new IllegalArgumentException("Missing 'imageTags' or 'imageTags' in the input variable");
+    }
+
+    private static <T> List<List<T>> partitions(List<T> list, int size) {
+        List<List<T>> parts = new ArrayList<>();
+        for (int i = 0; i < list.size(); i += size) {
+            parts.add(new ArrayList<>(
+                    list.subList(i, Math.min(list.size(), i + size)))
+            );
+        }
+        return parts;
+    }
 }