From 3e9ac438003dfed03e80db5c55cc3d9e01e1c8ab Mon Sep 17 00:00:00 2001
From: ben <ben@qoherent.ai>
Date: Wed, 1 Apr 2026 14:08:13 -0400
Subject: [PATCH 1/2] reporting campaign status

---
 src/ria_toolkit_oss/agent.py | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/src/ria_toolkit_oss/agent.py b/src/ria_toolkit_oss/agent.py
index 4bb152c..bd4b3fc 100644
--- a/src/ria_toolkit_oss/agent.py
+++ b/src/ria_toolkit_oss/agent.py
@@ -226,8 +226,11 @@ class NodeAgent:
             result = executor.run()
             logger.info("Campaign %s completed — uploading recordings", campaign_id[:8])
             self._upload_recordings(campaign_id, config, result)
+            result_dict = result.to_dict() if hasattr(result, "to_dict") else None
+            self._report_campaign_status(campaign_id, "completed", result=result_dict)
         except Exception as exc:
             logger.error("Campaign %s failed: %s", campaign_id[:8], exc)
+            self._report_campaign_status(campaign_id, "failed", error=str(exc))
 
     # ------------------------------------------------------------------
     # Recording upload (chunked for large files)
@@ -268,6 +271,30 @@ class NodeAgent:
                 except Exception as exc:
                     logger.warning("Campaign %s: upload of %s failed: %s", campaign_id[:8], filename, exc)
 
+    def _report_campaign_status(
+        self,
+        campaign_id: str,
+        status: str,
+        result: "dict | None" = None,
+        error: "str | None" = None,
+    ) -> None:
+        """POST campaign completion/failure back to the hub so GET /status/{id} resolves."""
+        payload: dict = {"campaign_id": campaign_id, "status": status}
+        if result is not None:
+            payload["result"] = result
+        if error is not None:
+            payload["error"] = error
+        try:
+            resp = self._post(
+                f"/orchestrator/nodes/{self.node_id}/campaign-status",
+                json=payload,
+                timeout=15,
+            )
+            resp.raise_for_status()
+            logger.info("Campaign %s: reported status=%s to hub", campaign_id[:8], status)
+        except Exception as exc:
+            logger.warning("Campaign %s: failed to report status to hub: %s", campaign_id[:8], exc)
+
     def _upload_file(self, base_url: str, file_path: str, metadata: dict) -> dict:
         """Upload *file_path*, choosing chunked or direct path based on file size."""
         import requests as _requests

From da9a0b07bdc8e8850d3fbb297b9c3309abc2471f Mon Sep 17 00:00:00 2001
From: ben <ben@qoherent.ai>
Date: Wed, 1 Apr 2026 15:05:30 -0400
Subject: [PATCH 2/2] poetry update

---
 poetry.lock | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/poetry.lock b/poetry.lock
index db5aab1..d2ddd55 100644
--- a/poetry.lock
+++ b/poetry.lock
@@ -688,14 +688,14 @@ test = ["pytest (>=6)"]
 
 [[package]]
 name = "fastapi"
-version = "0.135.2"
+version = "0.135.3"
 description = "FastAPI framework, high performance, easy to learn, fast to code, ready for production"
 optional = false
 python-versions = ">=3.10"
 groups = ["server", "test"]
 files = [
-    {file = "fastapi-0.135.2-py3-none-any.whl", hash = "sha256:0af0447d541867e8db2a6a25c23a8c4bd80e2394ac5529bd87501bbb9e240ca5"},
-    {file = "fastapi-0.135.2.tar.gz", hash = "sha256:88a832095359755527b7f63bb4c6bc9edb8329a026189eed83d6c1afcf419d56"},
+    {file = "fastapi-0.135.3-py3-none-any.whl", hash = "sha256:9b0f590c813acd13d0ab43dd8494138eb58e484bfac405db1f3187cfc5810d98"},
+    {file = "fastapi-0.135.3.tar.gz", hash = "sha256:bd6d7caf1a2bdd8d676843cdcd2287729572a1ef524fc4d65c17ae002a1be654"},
 ]
 
 [package.dependencies]