prevent NPE

conductor-oss · Feb 14, 2024 · a42a0cf · a42a0cf
1 parent 41dfa33
commit a42a0cf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/java/com/netflix/conductor/service/ExecutionService.java b/core/src/main/java/com/netflix/conductor/service/ExecutionService.java
@@ -187,6 +187,7 @@ public List<Task> poll(
         }
         taskIds.stream()
                 .map(executionDAOFacade::getTaskModel)
+                .filter(Objects::nonNull)
                 .filter(task -> TaskModel.Status.IN_PROGRESS.equals(task.getStatus()))
                 .forEach(taskStatusListener::onTaskInProgress);
         executionDAOFacade.updateTaskLastPoll(taskType, domain, workerId);