Check Background Jobs

POST /v1/workspaces/{workspaceId}/background-jobs

curl -X POST \
  'https://api.sharely.ai/v1/workspaces/{workspaceId}/background-jobs' \
  -H 'Authorization: Bearer YOUR_ACCESS_TOKEN' \
  -H 'Content-Type: application/json' \
  -H 'organizationid: your-organization-id' \
  -d '{
    "jobIds": ["job-uuid-1", "job-uuid-2"]
  }'

{
  "jobs": [
    {
      "id": "job-uuid-1",
      "status": "COMPLETED",
      "type": "ROLE_ASSIGNMENT",
      "createdAt": "2024-11-14T15:30:00Z",
      "completedAt": "2024-11-14T15:30:05Z",
      "result": {
        "assignedCount": 150,
        "knowledgeId": "knowledge-uuid"
      }
    },
    {
      "id": "job-uuid-2",
      "status": "RUNNING",
      "type": "ROLE_DELETION",
      "createdAt": "2024-11-14T15:31:00Z",
      "progress": 65
    },
    {
      "id": "job-uuid-3",
      "status": "FAILED",
      "type": "KNOWLEDGE_UPLOAD",
      "createdAt": "2024-11-14T15:29:00Z",
      "failedAt": "2024-11-14T15:29:10Z",
      "error": {
        "code": "PROCESSING_ERROR",
        "message": "Failed to extract text from PDF"
      }
    }
  ]
}

const fetch = require('node-fetch');
 
async function waitForJobs(workspaceId, jobIds, accessToken, organizationId) {
  const maxAttempts = 30;
  const pollInterval = 2000; // 2 seconds
 
  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    const response = await fetch(
      `https://api.sharely.ai/v1/workspaces/${workspaceId}/background-jobs`,
      {
        method: 'POST',
        headers: {
          'Authorization': `Bearer ${accessToken}`,
          'Content-Type': 'application/json',
          'organizationid': organizationId
        },
        body: JSON.stringify({ jobIds })
      }
    );
 
    const data = await response.json();
 
    // Check if all jobs are done
    const allDone = data.jobs.every(job =>
      ['COMPLETED', 'FAILED', 'CANCELLED'].includes(job.status)
    );
 
    if (allDone) {
      return data.jobs;
    }
 
    // Wait before next poll
    await new Promise(resolve => setTimeout(resolve, pollInterval));
  }
 
  throw new Error('Jobs did not complete within timeout');
}

import requests
import time
 
def check_background_jobs(workspace_id, job_ids, access_token, organization_id):
    max_attempts = 30
    base_interval = 1  # Start with 1 second
 
    for attempt in range(max_attempts):
        response = requests.post(
            f'https://api.sharely.ai/v1/workspaces/{workspace_id}/background-jobs',
            headers={
                'Authorization': f'Bearer {access_token}',
                'Content-Type': 'application/json',
                'organizationid': organization_id
            },
            json={'jobIds': job_ids}
        )
 
        response.raise_for_status()
        data = response.json()
 
        # Check if all jobs are complete
        all_done = all(
            job['status'] in ['COMPLETED', 'FAILED', 'CANCELLED']
            for job in data['jobs']
        )
 
        if all_done:
            return data['jobs']
 
        # Exponential backoff
        wait_time = min(base_interval * (2 ** attempt), 30)
        time.sleep(wait_time)
 
    raise TimeoutError('Jobs did not complete within timeout')