Canary

flame/star/star_model.py

@@ -58,6 +58,8 @@ def __init__(self,
             raise BrokenPipeError("Has to be either analyzer or aggregator")
         if not self.test_mode:
             self.flame.flame_log("Analysis finished!", log_type='info')
+            while True:
+                pass  # keep the node alive to allow for orderly shutdown
 
     def _is_aggregator(self) -> bool:
         return self.flame.get_role() == 'aggregator'
@@ -136,7 +138,6 @@ def _start_analyzer(self,
             self._get_data(query=query, data_type=data_type)
             self.flame.flame_log(f"\tData extracted: {str(self.data)[:100]}", log_type='info')
 
-            agg_res = None
             # Check converged status on Hub
             while not analyzer.finished:  # (**)
                 # Analyze data

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "flame"
-version = "0.4.0"
+version = "0.4.1"
 description = ""
 authors = ["Alexander Röhl <alexander.roehl@uni-tuebingen.de>", "David Hieber <david.hieber@uni-tuebingen.de>"]
 readme = "README.md"
@@ -9,7 +9,7 @@ packages = [{ include = "flame" }]
 
 [tool.poetry.dependencies]
 python = "^3.9"
-flamesdk = {git = "https://github.com/PrivateAIM/python-sdk.git", tag = "0.3.1"}
+flamesdk = {git = "https://github.com/PrivateAIM/python-sdk.git", tag = "0.3.1" }
 
 [tool.poetry.group.dev.dependencies]
 pytest = ">=8.3.0"