ISICO-14903: task status info log added

CiscoM31 · Oct 31, 2023 · b596300 · b596300
1 parent 3783508
commit b596300
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 4 deletions.
diff --git a/...listener/src/main/java/com/netflix/conductor/contribs/listener/task/TaskNotification.java b/...listener/src/main/java/com/netflix/conductor/contribs/listener/task/TaskNotification.java
@@ -11,12 +11,11 @@
  */
 package com.netflix.conductor.contribs.listener.task;
 
-
-import com.netflix.conductor.common.run.TaskLog;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.netflix.conductor.common.metadata.tasks.Task;
+import com.netflix.conductor.common.run.TaskLog;
 
 import com.fasterxml.jackson.annotation.JsonFilter;
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -31,6 +30,7 @@ public class TaskNotification extends TaskLog {
     private static final Logger LOGGER = LoggerFactory.getLogger(TaskStatusPublisher.class);
 
     public String workflowTaskType;
+
     /**
      * following attributes doesnt exist in TaskSummary so add it here. Not adding in TaskSummary as
      * it belongs to conductor-common

diff --git a/...tener/src/main/java/com/netflix/conductor/contribs/listener/task/TaskStatusPublisher.java b/...tener/src/main/java/com/netflix/conductor/contribs/listener/task/TaskStatusPublisher.java
@@ -112,6 +112,12 @@ public TaskStatusPublisher(
         this.rcm = rcm;
         this.executionDAOFacade = executionDAOFacade;
         this.subscribedTaskStatusList = subscribedTaskStatuses;
+        if (this.subscribedTaskStatusList.isEmpty()) {
+            LOGGER.error(
+                    "SubscribedTaskStatusList is empty. None of the notification might be sent to fusion");
+        } else {
+            LOGGER.info("SubscribedTaskStatusList {}", this.subscribedTaskStatusList);
+        }
         ConsumerThread consumerThread = new ConsumerThread();
         consumerThread.start();
     }
@@ -127,7 +133,8 @@ public void onTaskScheduled(TaskModel task) {
                     "Failed to enqueue task: Id {} Type {} of workflow {} ",
                     task.getTaskId(),
                     task.getTaskType(),
-                    task.getWorkflowInstanceId(),e);
+                    task.getWorkflowInstanceId(),
+                    e);
         }
     }
 
@@ -139,7 +146,8 @@ private void enqueueTask(TaskModel task) {
                     "Failed to enqueue task: Id {} Type {} of workflow {} ",
                     task.getTaskId(),
                     task.getTaskType(),
-                    task.getWorkflowInstanceId(),e);
+                    task.getWorkflowInstanceId(),
+                    e);
         }
     }