Address comments

Author: harshach

openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/PipelineResourceIT.java

@@ -1299,6 +1299,7 @@ void put_pipelineStatusReindexesDownstreamLineage_200_OK(TestNamespace ns) throw
     assertEquals(StatusType.Successful, updatedPipeline.getPipelineStatus().getExecutionStatus());
     assertEquals(pipelineStatus.getTimestamp(), updatedPipeline.getPipelineStatus().getTimestamp());
   }
+
   // ===================================================================
   // BULK API SUPPORT
   // ===================================================================

openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/PipelineRepository.java

@@ -388,7 +388,7 @@ public RestUtil.PutResponse<?> addBulkPipelineStatus(
 
     Set<String> validatedTasks = new HashSet<>();
     for (PipelineStatus pipelineStatus : pipelineStatuses) {
-      for (Status taskStatus : pipelineStatus.getTaskStatus()) {
+      for (Status taskStatus : listOrEmpty(pipelineStatus.getTaskStatus())) {
         if (validatedTasks.add(taskStatus.getName())) {
           validateTask(pipeline, taskStatus.getName());
         }
@@ -416,7 +416,11 @@ public RestUtil.PutResponse<?> addBulkPipelineStatus(
     pipeline.setChangeDescription(change);
     pipeline.setIncrementalChangeDescription(change);
 
-    searchRepository.updateEntityIndex(pipeline);
+    try {
+      searchRepository.updateEntityIndex(pipeline);
+    } catch (Exception e) {
+      LOG.error("Failed to update pipeline entity index in Elasticsearch", e);
+    }
 
     return new RestUtil.PutResponse<>(
         Response.Status.OK,