(self, cluster_id: str, job_id: str)
| 86 | raise AgentRPCError(f"Failed to create job: {str(e)}") |
| 87 | |
| 88 | def get_job(self, cluster_id: str, job_id: str) -> Dict[str, Any]: |
| 89 | try: |
| 90 | query_params = { |
| 91 | "waitTime": "20", |
| 92 | } |
| 93 | response = self.get( |
| 94 | f"/clusters/{cluster_id}/jobs/{job_id}", params=query_params |
| 95 | ) |
| 96 | return {"status": 200, "body": response} |
| 97 | except Exception as e: |
| 98 | raise AgentRPCError(f"Failed to get job details: {str(e)}") |
| 99 | |
| 100 | def poll_for_job_completion( |
| 101 | self, |
no test coverage detected