160 make dag progress bar optional (#162)

* closes #160. progress bar optional, plus untested dag bugfix.

* closes #160. second dag bugfix.

CHANGELOG.rst

@@ -1,3 +1,12 @@
+Mass_Composition 0.6.2 (2024-05-16)
+===================================
+
+Bugfix
+------
+
+- Second fix for DAG.run ValueError('generator already running') - managed result type. (160a)
+
+
 Mass_Composition 0.6.1 (2024-05-16)
 ===================================
 

elphick/mass_composition/dag.py

@@ -237,7 +237,13 @@ def execute_node(self, node: str, strms: dict):
                 for successor in self.graph.successors(node):
                     updated_edges[(node, successor)] = result
 
-        return node, list(result), updated_edges
+        # Check the type of the result
+        if isinstance(result, MassComposition):
+            # If the result is a Stream object, return it as is
+            return node, result, updated_edges
+        else:
+            # If the result is a generator or a tuple of Stream objects, convert it to a list
+            return node, list(result), updated_edges
 
     def plot(self):
         plt.figure(figsize=(8, 6))

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "mass-composition"
-version = "0.6.1"
+version = "0.6.2"
 description = "For managing multi-dimensional mass-composition datasets, supporting weighted mathematical operations and visualisation."
 authors = ["Greg <greg@elphick.com.au>"]
 packages = [{ include = "elphick/mass_composition" }]

scripts/bump_version.py

@@ -5,9 +5,6 @@
 
 def run_command(command):
     process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-    stdout, stderr = process.communicate()
-    print(f"stdout: {stdout.decode()}")
-    print(f"stderr: {stderr.decode()}")
     process.wait()