Get async status

curl -X GET "https://api.cloro.dev/v1/async/status" \
  -H "Authorization: Bearer YOUR_API_KEY"

{
  "queuedTasks": 3,
  "processingTasks": 2,
  "priorityBreakdown": [
    { "priority": 10, "count": 1 },
    { "priority": 5, "count": 1 },
    { "priority": 1, "count": 1 }
  ],
  "concurrency": {
    "used": 2,
    "max": 5
  }
}

import axios from 'axios';

const API_KEY = process.env.API_KEY;
const STATUS_URL = 'https://api.cloro.dev/v1/async/status';

async function checkQueueStatus() {
  try {
    const response = await axios.get(STATUS_URL, {
      headers: {
        'Authorization': `Bearer ${API_KEY}`
      }
    });

    const { queuedTasks, processingTasks, priorityBreakdown, concurrency } = response.data;

    console.log(`Queue status:`);
    console.log(`  Queued: ${queuedTasks} tasks`);
    console.log(`  Processing: ${processingTasks} tasks`);

    if (priorityBreakdown.length > 0) {
      console.log(`  Priority breakdown:`);
      for (const { priority, count } of priorityBreakdown) {
        console.log(`    Priority ${priority}: ${count} tasks`);
      }
    }

    if (concurrency) {
      console.log(`  Concurrency: ${concurrency.used}/${concurrency.max} slots used`);
      console.log(`  Available: ${concurrency.max - concurrency.used} slots`);
    }

    // Alert if queue is getting large
    if (queuedTasks > 100) {
      console.warn('Warning: Queue has over 100 tasks waiting');
    }

    // Alert if approaching concurrency limit
    if (concurrency && concurrency.used / concurrency.max > 0.8) {
      console.warn('Warning: Using over 80% of concurrency limit');
    }

    return response.data;
  } catch (error) {
    console.error('Error checking queue status:', error.message);
    throw error;
  }
}

// Check status every 30 seconds
setInterval(checkQueueStatus, 30000);

import requests
import time

API_KEY = 'YOUR_API_KEY'
STATUS_URL = 'https://api.cloro.dev/v1/async/status'

def check_queue_status():
    try:
        response = requests.get(
            STATUS_URL,
            headers={'Authorization': f'Bearer {API_KEY}'}
        )
        response.raise_for_status()

        data = response.json()
        queued_tasks = data['queuedTasks']
        processing_tasks = data['processingTasks']
        priority_breakdown = data.get('priorityBreakdown', [])
        concurrency = data.get('concurrency')

        print(f'Queue status:')
        print(f'  Queued: {queued_tasks} tasks')
        print(f'  Processing: {processing_tasks} tasks')

        if priority_breakdown:
            print(f'  Priority breakdown:')
            for entry in priority_breakdown:
                print(f'    Priority {entry["priority"]}: {entry["count"]} tasks')

        if concurrency:
            used = concurrency['used']
            max_concurrent = concurrency['max']
            available = max_concurrent - used
            print(f'  Concurrency: {used}/{max_concurrent} slots used')
            print(f'  Available: {available} slots')

            # Alert if approaching concurrency limit
            if used / max_concurrent > 0.8:
                print('Warning: Using over 80% of concurrency limit')

        # Alert if queue is getting large
        if queued_tasks > 100:
            print('Warning: Queue has over 100 tasks waiting')

        return data

    except requests.exceptions.RequestException as e:
        print(f'Error checking queue status: {e}')
        raise

# Check status every 30 seconds
while True:
    check_queue_status()
    time.sleep(30)