poetry.lock

@@ -688,14 +688,14 @@ test = ["pytest (>=6)"]
 
 [[package]]
 name = "fastapi"
-version = "0.135.3"
+version = "0.135.2"
 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.3-py3-none-any.whl", hash = "sha256:9b0f590c813acd13d0ab43dd8494138eb58e484bfac405db1f3187cfc5810d98"},
-    {file = "fastapi-0.135.3.tar.gz", hash = "sha256:bd6d7caf1a2bdd8d676843cdcd2287729572a1ef524fc4d65c17ae002a1be654"},
+    {file = "fastapi-0.135.2-py3-none-any.whl", hash = "sha256:0af0447d541867e8db2a6a25c23a8c4bd80e2394ac5529bd87501bbb9e240ca5"},
+    {file = "fastapi-0.135.2.tar.gz", hash = "sha256:88a832095359755527b7f63bb4c6bc9edb8329a026189eed83d6c1afcf419d56"},
 ]
 
 [package.dependencies]

src/ria_toolkit_oss/agent.py

@@ -226,11 +226,8 @@ 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)
@@ -271,30 +268,6 @@ 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