I dont understand drone lint

OpenCTI-Platform · Jan 24, 2025 · cb2dfd3 · cb2dfd3
1 parent ed3817f
commit cb2dfd3
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/opencti-platform/opencti-graphql/src/manager/ingestionManager.ts b/opencti-platform/opencti-graphql/src/manager/ingestionManager.ts
@@ -273,7 +273,8 @@ const rssExecutor = async (context: AuthContext, turndownService: TurndownServic
       ingestionPromises.push(ingestionPromise);
     } else {
       // Update the state
-      const ingestionPromise = updateBuiltInConnectorInfo(context, ingestion.user_id, ingestion.id, { buffering: true, messages_size });
+      const ingestionPromise = updateBuiltInConnectorInfo(context, ingestion.user_id, ingestion.id, { buffering: true, messages_size })
+        .catch((reason) => logApp.error('[OPENCTI-MODULE] INGESTION error', { cause: reason }));
       ingestionPromises.push(ingestionPromise);
     }
   }
@@ -448,7 +449,8 @@ const taxiiExecutor = async (context: AuthContext) => {
       ingestionPromises.push(ingestionPromise);
     } else {
       // Update the state
-      const ingestionPromise = updateBuiltInConnectorInfo(context, ingestion.user_id, ingestion.id, { buffering: true, messages_size });
+      const ingestionPromise = updateBuiltInConnectorInfo(context, ingestion.user_id, ingestion.id, { buffering: true, messages_size })
+        .catch((reason) => logApp.error('[OPENCTI-MODULE] INGESTION error', { cause: reason }));
       ingestionPromises.push(ingestionPromise);
     }
   }
@@ -530,7 +532,8 @@ const csvExecutor = async (context: AuthContext) => {
       ingestionPromises.push(ingestionPromise);
     } else {
       // Update the state
-      const ingestionPromise = updateBuiltInConnectorInfo(context, ingestion.user_id, ingestion.id, { buffering: true, messages_size });
+      const ingestionPromise = updateBuiltInConnectorInfo(context, ingestion.user_id, ingestion.id, { buffering: true, messages_size })
+        .catch((reason) => logApp.error('[OPENCTI-MODULE] INGESTION error', { cause: reason }));
       ingestionPromises.push(ingestionPromise);
     }
   }