[Hotfix] propagate change to consumer...

astrolabsoftware · Mar 29, 2021 · 700f579 · 700f579
1 parent a0cf98b
commit 700f579
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/fink_client/consumer.py b/fink_client/consumer.py
@@ -145,6 +145,10 @@ def consume(self, num_alerts: int = 1, timeout: float = -1) -> list:
             if type(key) == bytes:
                 key = key.decode('utf8')
 
+            if key is None:
+                # backward compatibility
+                key = '1.0_0.4.3'
+
             # Get the schema
             if self.schema_path is not None:
                 _parsed_schema = _get_alert_schema(schema_path=self.schema_path)