Finish removing task ID from IngestJobValidatedEvent

gchq · Feb 21, 2025 · 04467c4 · 04467c4
1 parent 6d20c91
commit 04467c4
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 6 deletions.
diff --git a/java/core/src/main/java/sleeper/core/tracker/ingest/job/update/IngestJobEvent.java b/java/core/src/main/java/sleeper/core/tracker/ingest/job/update/IngestJobEvent.java
@@ -39,7 +39,9 @@ public interface IngestJobEvent {
      *
      * @return the ID, or null if the event did not occur on a task
      */
-    String getTaskId();
+    default String getTaskId() {
+        return null;
+    }
 
     /**
      * Gets the correlation ID for the run of the ingest job.

diff --git a/java/core/src/main/java/sleeper/core/tracker/ingest/job/update/IngestJobValidatedEvent.java b/java/core/src/main/java/sleeper/core/tracker/ingest/job/update/IngestJobValidatedEvent.java
@@ -80,10 +80,6 @@ public String getJobRunId() {
         return jobRunId;
     }
 
-    public String getTaskId() {
-        return null;
-    }
-
     public Instant getValidationTime() {
         return validationTime;
     }

diff --git a/...ngest-tracker/src/main/java/sleeper/ingest/tracker/job/DynamoDBIngestJobStatusFormat.java b/...ngest-tracker/src/main/java/sleeper/ingest/tracker/job/DynamoDBIngestJobStatusFormat.java
@@ -106,7 +106,6 @@ public static Map<String, AttributeValue> createJobValidatedUpdate(
                 .string(JSON_MESSAGE, event.getJsonMessage())
                 .number(INPUT_FILES_COUNT, event.getFileCount())
                 .string(JOB_RUN_ID, event.getJobRunId())
-                .string(TASK_ID, event.getTaskId())
                 .build();
     }