found a fork that fixes the VertexCommand bug, see #5

ehrenb · Dec 14, 2022 · 0166d66 · 0166d66
1 parent 19e875a
commit 0166d66
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/images/base/requirements.txt b/images/base/requirements.txt
@@ -1,5 +1,6 @@
 jsonschema
 pika
-git+https://github.com/orientechnologies/pyorient.git@ca7690a95f57262b6b91f3545ac98def052d4193#egg=pyorient
+git+https://github.com/baesystemsFASTLabs/pyorient.git@7e46e166e616bcfea1ccdc31d5e7187f7bbce806#egg=pyorient
+# git+https://github.com/orientechnologies/pyorient.git@ca7690a95f57262b6b91f3545ac98def052d4193#egg=pyorient
 # -e git+https://github.com/alanmeeson/pyorient.git@0317a87369675df9b33fd38af451099c3c011d40#egg=pyorient
 # -e git+https://github.com/brucetony/pyorient.git@ec328f2b4f51664819e48895b86f8912d22415a6#egg=pyorient
diff --git a/images/identifier/src/identifier.py b/images/identifier/src/identifier.py
@@ -135,7 +135,7 @@ def _resolve_supported_type(fpath):
         origin_node = None
         if 'origin' in data.keys():
             # Retrieve the originating Node cls from the database
-             origin_node = self.graph.get_vertex(data['origin']['id'])
+            origin_node = self.graph.get_vertex(data['origin']['id'])
 
         # If the resolved originating hash matches the given hash
         # this is a retype of a previous Node.
@@ -159,11 +159,11 @@ def _resolve_supported_type(fpath):
             # publish to resolved type routing key
             channel = self.get_channel(self.config['rabbitmq'])
             channel.basic_publish(exchange='machina',
-                                   routing_key=resolved_type,
-                                   body=json.dumps(body))
+                routing_key=resolved_type,
+                body=json.dumps(body))
 
             channel = self.get_channel(self.config['rabbitmq'])
             # publish to wildcard routing key
             channel.basic_publish(exchange='machina',
-                                   routing_key='*',
-                                   body=json.dumps(body))
+                routing_key='*',
+                body=json.dumps(body))