[backend] Fix resolution

OpenCTI-Platform · Oct 23, 2023 · a855f30 · a855f30
1 parent bcdee54
commit a855f30
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 11 deletions.
diff --git a/opencti-platform/opencti-graphql/src/database/middleware.js b/opencti-platform/opencti-graphql/src/database/middleware.js
@@ -1985,14 +1985,11 @@ export const updateAttribute = async (context, user, id, type, inputs, opts = {}
         if (relType === RELATION_GRANTED_TO && !isUserHasCapability(user, KNOWLEDGE_ORGANIZATION_RESTRICT)) {
           throw ForbiddenAccess();
         }
-
         let { value: refs, operation = UPDATE_OPERATION_REPLACE } = meta[metaIndex];
-
         if (relType === RELATION_OBJECT_MARKING) {
           const markingsCleaned = await handleMarkingOperations(context, initial.objectMarking, refs, operation);
           ({ operation, refs } = { operation: markingsCleaned.operation, refs: markingsCleaned.refs });
         }
-
         if (operation === UPDATE_OPERATION_REPLACE) {
           // Delete all relations
           const currentRels = await listAllRelations(context, user, relType, { fromId: id });

diff --git a/opencti-worker/src/worker.py b/opencti-worker/src/worker.py
@@ -274,24 +274,24 @@ def data_handler(  # pylint: disable=too-many-statements, too-many-locals
             else:
                 # Unknown type, just move on.
                 return True
-        except Timeout:
-            error_msg = traceback.format_exc()
+        except Timeout as ex:
+            error = str(ex)
             bundles_timeout_error_counter.add(1)
             self.api.log(
-                "warning", "A connection timeout occurred: {{ " + error_msg + " }}"
+                "warning", "A connection timeout occurred: {{ " + error + " }}"
             )
+            time.sleep(30)
             # Platform is under heavy load: wait for unlock & retry almost indefinitely.
             sleep_jitter = round(random.uniform(10, 30), 2)
             time.sleep(sleep_jitter)
             self.data_handler(connection, channel, delivery_tag, data)
             return True
-        except RequestException:
-            error_msg = traceback.format_exc()
+        except RequestException as ex:
+            error = str(ex)
             bundles_request_error_counter.add(1, {"origin": "opencti-worker"})
             self.api.log(
-                "error", "A connection error occurred: {{ " + error_msg + " }}"
+                "error", "A connection error occurred: {{ " + error + " }}"
             )
-            time.sleep(60)
             self.api.log(
                 "info",
                 "Message (delivery_tag="
@@ -348,11 +348,12 @@ def data_handler(  # pylint: disable=too-many-statements, too-many-locals
                         },
                     )
                 return False
-            elif "ConnectionError" in error_msg:
+            elif "Bad Gateway" in error_msg:
                 bundles_bad_gateway_error_counter.add(1)
                 self.api.log(
                     "error", "A connection error occurred: {{ " + error + " }}"
                 )
+                time.sleep(30)
                 self.api.log(
                     "info",
                     "Message (delivery_tag="