Merge pull request #15 from qua-platform/stop_route

Stop running item api

qualibrate_runner/api/routes/others.py

@@ -20,6 +20,13 @@ def check_running(
     return state.is_running
 
 
+@others_router.post("/stop")
+def stop_running(state: Annotated[State, Depends(get_state)]) -> bool:
+    if state.run_item is None:
+        return False
+    return bool(state.run_item.stop())
+
+
 @others_router.post(
     "/record_state_update",
     description=(

qualibrate_runner/core/run_job.py

@@ -24,6 +24,12 @@ def validate_input_parameters(
         )
 
 
+def get_active_library_or_error() -> QualibrationLibrary:
+    if QualibrationLibrary.active_library is None:
+        raise RuntimeError("Qualibration library is not exist")
+    return QualibrationLibrary.active_library
+
+
 def run_node(
     node: QualibrationNode,
     passed_input_parameters: Mapping[str, Any],
@@ -38,7 +44,7 @@ def run_node(
         started_at=datetime.now(),
     )
     try:
-        library = QualibrationLibrary.active_library
+        library = get_active_library_or_error()
         node = library.nodes[node.name]
         result = library.run_node(
             node.name, node.parameters_class(**passed_input_parameters)
@@ -85,7 +91,7 @@ def run_workflow(
     )
     state.run_item = workflow
     try:
-        library = QualibrationLibrary.active_library
+        library = get_active_library_or_error()
         workflow = library.graphs[workflow.name]
         result = library.run_graph(
             workflow.name,