git job status added

Author: Khauneesh-AI

app/main.py

@@ -87,6 +87,23 @@
 )
 runtime_identifier = template_job.runtime_identifier
 
+def get_job_status( job_id: str) -> str:
+    """
+    Get the status of a job run
+    
+    Args:
+        job_id (str): The ID of the job to check
+        
+    Returns:
+        str: The status of the most recent job run
+    """
+    response = client_cml.list_job_runs(
+        project_id, 
+        job_id, 
+        sort="-created_at", 
+        page_size=1
+    )
+    return response.job_runs[0].status
 
 def get_total_size(file_paths):
 

app/services/synthesis_job.py

@@ -140,7 +140,7 @@ def generate_job(self, request: Any, cpu: int = 2, memory: int = 4) -> Dict[str,
             'input_path': synthesis_service.safe_json_dumps(getattr(request, 'input_path', None)),
             'job_name': job_name,
             'job_id': job_run.job_id,
-            'job_status': get_job_status(job_run.job_id),
+            'job_status': self.get_job_status(job_run.job_id),
             'input_key': request.input_key,
             'output_key': request.output_key,
             'output_value': request.output_value,