fix for failing put listener tests

ClusterlessHQ · Oct 5, 2023 · 86746ef · 86746ef
1 parent febf36a
commit 86746ef
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/...aws-lambda-transform-model/src/main/java/clusterless/lambda/transform/TransformProps.java b/...aws-lambda-transform-model/src/main/java/clusterless/lambda/transform/TransformProps.java
@@ -24,7 +24,7 @@ public class TransformProps implements Struct {
     @JsonProperty(required = true)
     protected Dataset dataset;
     protected String eventBusName;
-    protected PathFilter filter;
+    protected PathFilter filter = new PathFilter();
 
     public String lotUnit() {
         return lotUnit;

diff --git a/...src/main/java/clusterless/lambda/transform/frequents3put/FrequentS3PutTransformProps.java b/...src/main/java/clusterless/lambda/transform/frequents3put/FrequentS3PutTransformProps.java
@@ -51,7 +51,7 @@ public static final class Builder {
         protected ManifestURI manifestPartialPath;
         protected Dataset dataset;
         protected String eventBusName;
-        protected PathFilter filter;
+        protected PathFilter filter = new PathFilter();
         protected String sqsQueueName;
         protected int sqsWaitTimeSeconds = 0;
 
@@ -104,14 +104,14 @@ public Builder withSqsWaitTimeSeconds(int sqsWaitTimeSeconds) {
 
         public FrequentS3PutTransformProps build() {
             FrequentS3PutTransformProps frequentS3PutTransformProps = new FrequentS3PutTransformProps();
-            frequentS3PutTransformProps.filter = this.filter;
-            frequentS3PutTransformProps.dataset = this.dataset;
-            frequentS3PutTransformProps.lotUnit = this.lotUnit;
             frequentS3PutTransformProps.manifestCompletePath = this.manifestCompletePath;
-            frequentS3PutTransformProps.manifestPartialPath = this.manifestPartialPath;
+            frequentS3PutTransformProps.lotUnit = this.lotUnit;
             frequentS3PutTransformProps.sqsQueueName = this.sqsQueueName;
             frequentS3PutTransformProps.sqsWaitTimeSeconds = this.sqsWaitTimeSeconds;
+            frequentS3PutTransformProps.manifestPartialPath = this.manifestPartialPath;
             frequentS3PutTransformProps.eventBusName = this.eventBusName;
+            frequentS3PutTransformProps.dataset = this.dataset;
+            frequentS3PutTransformProps.filter = this.filter;
             return frequentS3PutTransformProps;
         }
     }

diff --git a/...transform-model/src/main/java/clusterless/lambda/transform/s3put/S3PutTransformProps.java b/...transform-model/src/main/java/clusterless/lambda/transform/s3put/S3PutTransformProps.java
@@ -58,7 +58,7 @@ public static final class Builder {
         protected ManifestURI manifestPartialPath;
         protected Dataset dataset;
         protected String eventBusName;
-        protected PathFilter filter;
+        protected PathFilter filter = new PathFilter();
         LotSource lotSource;
         String keyRegex;
 
@@ -111,14 +111,14 @@ public Builder withKeyRegex(String keyRegex) {
 
         public S3PutTransformProps build() {
             S3PutTransformProps s3PutTransformProps = new S3PutTransformProps();
-            s3PutTransformProps.filter = this.filter;
             s3PutTransformProps.lotSource = this.lotSource;
-            s3PutTransformProps.dataset = this.dataset;
+            s3PutTransformProps.manifestCompletePath = this.manifestCompletePath;
             s3PutTransformProps.keyRegex = this.keyRegex;
             s3PutTransformProps.lotUnit = this.lotUnit;
-            s3PutTransformProps.manifestCompletePath = this.manifestCompletePath;
             s3PutTransformProps.manifestPartialPath = this.manifestPartialPath;
             s3PutTransformProps.eventBusName = this.eventBusName;
+            s3PutTransformProps.dataset = this.dataset;
+            s3PutTransformProps.filter = this.filter;
             return s3PutTransformProps;
         }
     }