Method create_and_poll_job

sdk-python/src/agentrpc/http_client.py:130–160

Create a job and poll for completion. Args: cluster_id: The cluster ID. tool_name: The tool name. input_data: The input data. Returns: The final job status, result, and result type. Raises: AgentRPCError: If the r

(
        self, cluster_id: str, tool_name: str, input_data: Dict[str, Any]
    )

        return {"status": status, "result": result, "resultType": result_type}

    def create_and_poll_job(
        self, cluster_id: str, tool_name: str, input_data: Dict[str, Any]
    ) -> Dict[str, str]:
        """Create a job and poll for completion.

        Args:
            cluster_id: The cluster ID.
            tool_name: The tool name.
            input_data: The input data.

        Returns:
            The final job status, result, and result type.

        Raises:
            AgentRPCError: If the request fails.
        """
        # Create the job with maximum server-side wait time
        create_result = self.create_job(
            cluster_id=cluster_id,
            tool_name=tool_name,
            input_data=input_data,
        )

        # Poll for completion
        return self.poll_for_job_completion(
            cluster_id=cluster_id,
            job_id=create_result.get("id"),
            initial_status=create_result.get("status"),
            initial_result=create_result.get("result") or "",
            initial_result_type=create_result.get("resultType") or "rejection",
        )

    def get(self, path: str, params: Optional[Dict[str, Any]] = None) -> Any:
        """Make a GET request to the API.