fix: [zmq importer] fix object source name

2023-12-12 10:14:59 +01:00 · 2023-12-12 10:14:59 +01:00 · 4529a76d13
parent 2e38a96686
commit 4529a76d13
1 changed files with 1 additions and 1 deletions
--- a/bin/importer/ZMQImporter.py
+++ b/bin/importer/ZMQImporter.py
@ -76,7 +76,7 @@ class ZMQModuleImporter(AbstractModule):

            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