Wired in logic so we can run a single nodes workflow. Fixes #363

geest/gui/tree_panel.py

@@ -265,6 +265,9 @@ def open_context_menu(self, position: QPoint):
         )
         add_to_map_action = QAction("Add to map", self)
         add_to_map_action.triggered.connect(lambda: self.add_to_map(item))
+
+        run_item_action = QAction("Run Item Workflow", self)
+        run_item_action.triggered.connect(lambda: self.run_item(item, role=item.role))
         # Check the role of the item directly from the stored role
         if item.role == "dimension":
             # Context menu for dimensions
@@ -277,19 +280,21 @@ def open_context_menu(self, position: QPoint):
                 lambda: self.model.remove_item(item)
             )
             clear_action = QAction("Clear Factor Weightings", self)
-            auto_assign_action = QAction("Auto Assign Factor Weightings", self)
             clear_action.triggered.connect(
                 lambda: self.model.clear_factor_weightings(item)
             )
+            auto_assign_action = QAction("Auto Assign Factor Weightings", self)
             auto_assign_action.triggered.connect(
                 lambda: self.model.auto_assign_factor_weightings(item)
             )
+
             # Add actions to menu
             menu = QMenu(self)
             menu.addAction(clear_action)
             menu.addAction(auto_assign_action)
             menu.addAction(show_json_attributes_action)
             menu.addAction(add_to_map_action)
+            menu.addAction(run_item_action)
 
             if editing:
                 menu.addAction(add_factor_action)
@@ -329,6 +334,7 @@ def open_context_menu(self, position: QPoint):
                 menu.addAction(remove_factor_action)
             menu.addAction(clear_action)
             menu.addAction(auto_assign_action)
+            menu.addAction(run_item_action)
 
         elif item.role == "layer":
             # Context menu for layers
@@ -346,6 +352,7 @@ def open_context_menu(self, position: QPoint):
             menu.addAction(show_properties_action)
             menu.addAction(show_json_attributes_action)
             menu.addAction(add_to_map_action)
+            menu.addAction(run_item_action)
 
             if editing:
                 menu.addAction(remove_layer_action)
@@ -475,43 +482,40 @@ def _start_workflows(self, parent_item, role=None):
         """
         for i in range(parent_item.childCount()):
             child_item = parent_item.child(i)
+            self.queue_workflow_task(child_item, role)
+            # Recursively process children (dimensions, factors)
+            self._start_workflows(child_item, role)
 
-            # If the child is a layer, queue a workflow task
-            if child_item.role == role:
-                # Create the workflow task
-                task = None
-                if role == "layer":
-                    task = self.queue_manager.add_task(child_item.data(3))
-
-                elif role == "factor":
-                    task = self.queue_manager.add_task(child_item.getFactorAttributes())
-
-                elif role == "dimension":
-                    task = self.queue_manager.add_task(
-                        child_item.getDimensionAttributes()
-                    )
+    def queue_workflow_task(self, item, role):
+        """Queue a workflow task based on the role of the item."""
+        task = None
+        if role == item.role and role == "layer":
+            task = self.queue_manager.add_task(item.data(3))
+        if role == item.role and role == "factor":
+            task = self.queue_manager.add_task(item.getFactorAttributes())
+        if role == item.role and role == "dimension":
+            task = self.queue_manager.add_task(item.getDimensionAttributes())
+        if role == item.role and role == "analysis":
+            task = self.queue_manager.add_task(item.getAnalysisAttributes())
+
+        if task is None:
+            return
 
-                elif role == "analysis":
-                    task = self.queue_manager.add_task(
-                        child_item.getAnalysisAttributes()
-                    )
+        # Connect workflow signals to TreePanel slots
+        task.job_queued.connect(partial(self.on_workflow_created, item))
+        task.job_started.connect(partial(self.on_workflow_started, item))
+        task.job_canceled.connect(partial(self.on_workflow_completed, item, False))
+        task.job_finished.connect(
+            lambda success, attrs: self.on_workflow_completed(item, success)
+        )
 
-                if task is None:
-                    continue
-                # Connect workflow signals to TreePanel slots
-                task.job_queued.connect(partial(self.on_workflow_created, child_item))
-                task.job_started.connect(partial(self.on_workflow_started, child_item))
-                # task.job_completed.connect(partial(self.on_workflow_completed, child_item))
-                task.job_canceled.connect(
-                    partial(self.on_workflow_completed, child_item, False)
-                )
-                task.job_finished.connect(
-                    lambda success, attrs: self.on_workflow_completed(
-                        child_item, success
-                    )
-                )
-            # Recursively process children (dimensions, factors)
-            self._start_workflows(child_item, role)
+    def run_item(self, item, role):
+        self.queue_workflow_task(item, role)
+        debug_env = int(os.getenv("GEEST_DEBUG", 0))
+        if debug_env:
+            self.queue_manager.start_processing_in_foreground()
+        else:
+            self.queue_manager.start_processing()
 
     @pyqtSlot()
     def on_workflow_created(self, item):