fix: [zmq importer] fix object source name

ail-project · Dec 12, 2023 · 4529a76 · 4529a76
1 parent 2e38a96
commit 4529a76
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bin/importer/ZMQImporter.py b/bin/importer/ZMQImporter.py
@@ -76,7 +76,7 @@ def compute(self, messages):
 
             obj_id, gzip64encoded = message.split(' ', 1)  # TODO ADD LOGS
             splitted = obj_id.split('>>', 1)
-            if splitted == 2:
+            if len(splitted) == 2:
                 feeder_name, obj_id = splitted
             else:
                 feeder_name = self.default_feeder_name