Fix triggeredAt name

transferwise · Dec 18, 2024 · 0aa8dfe · 0aa8dfe
1 parent e995b03
commit 0aa8dfe
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/tw-tasks-core/src/main/java/com/transferwise/tasks/processing/TasksProcessingService.java b/tw-tasks-core/src/main/java/com/transferwise/tasks/processing/TasksProcessingService.java
@@ -213,7 +213,7 @@ protected ProcessTasksResponse processTasks(GlobalProcessingState.Bucket bucket)
           mdcService.put(task);
           try {
             ProcessTaskResponse processTaskResponse = grabTaskForProcessing(bucketId, task);
-            coreMetricsTemplate.registerTaskGrabbingResponse(bucketId, type, priority, processTaskResponse, taskTriggering.getTriggerAt());
+            coreMetricsTemplate.registerTaskGrabbingResponse(bucketId, type, priority, processTaskResponse, taskTriggering.getTriggeredAt());
 
             if (processTaskResponse.getResult() == ProcessTaskResponse.Result.NO_SPACE) {
               noRoomMap.put(type, Boolean.TRUE);

diff --git a/...ks-core/src/main/java/com/transferwise/tasks/triggering/KafkaTasksExecutionTriggerer.java b/...ks-core/src/main/java/com/transferwise/tasks/triggering/KafkaTasksExecutionTriggerer.java
@@ -184,7 +184,7 @@ public void trigger(BaseTask task) {
       TaskTriggering taskTriggering = new TaskTriggering()
           .setTask(task)
           .setBucketId(processingBucketId)
-          .setTriggerAt(Instant.now());
+          .setTriggeredAt(Instant.now());
       ITasksProcessingService.AddTaskForProcessingResponse addTaskForProcessingResponse = tasksProcessingService.addTaskForProcessing(taskTriggering);
 
       if (addTaskForProcessingResponse.getResult() == ITasksProcessingService.AddTaskForProcessingResponse.ResultCode.OK) {
@@ -292,7 +292,7 @@ public void poll(String bucketId) {
                 .setTask(task)
                 .setBucketId(bucketId)
                 .setOffset(offset)
-                .setTriggerAt(Instant.ofEpochMilli(consumerRecord.timestamp()))
+                .setTriggeredAt(Instant.ofEpochMilli(consumerRecord.timestamp()))
                 .setTopicPartition(topicPartition);
 
             coreMetricsTemplate.registerKafkaTasksExecutionTriggererTriggersReceive(bucketId);

diff --git a/tw-tasks-core/src/main/java/com/transferwise/tasks/triggering/TaskTriggering.java b/tw-tasks-core/src/main/java/com/transferwise/tasks/triggering/TaskTriggering.java
@@ -12,7 +12,7 @@ public class TaskTriggering {
 
   private BaseTask task;
   private long offset;
-  private Instant triggerAt;
+  private Instant triggeredAt;
   private long sequence;
   private TopicPartition topicPartition;
   private String bucketId;