Function batch_api_jobs

codeclash/viewer/app.py:1411–1446

API endpoint to get AWS Batch jobs with caching (2 min timeout) Concurrent requests are coalesced to prevent multiple simultaneous AWS API calls.

()

@app.route("/batch/api/jobs")
@print_timing
def batch_api_jobs():
    """API endpoint to get AWS Batch jobs with caching (2 min timeout)

    Concurrent requests are coalesced to prevent multiple simultaneous AWS API calls.
    """
    # Don't show batch API in static mode - skip freezing
    if STATIC_MODE:
        return redirect(url_for("index"))

    try:
        hours_back = request.args.get("hours_back", default=24, type=int)
        force_refresh = request.args.get("force_refresh", default="false", type=str).lower() == "true"

        cache_key = f"batch_jobs:{hours_back}"

        # If force_refresh is true, invalidate cache
        if force_refresh:
            _cache.invalidate(cache_key)
            logger.info("Force refresh requested, invalidating batch jobs cache")

        # Use get_or_compute to prevent concurrent AWS API calls
        def compute():
            try:
                return _fetch_batch_jobs_impl(hours_back)
            except TimeoutError:
                logger.error("Timeout while fetching AWS Batch jobs")
                raise  # Re-raise to be caught by outer handler

        result = _cache.get_or_compute(cache_key, compute, timeout_seconds=120)
        return jsonify({"success": True, **result})
    except TimeoutError:
        logger.error("Timeout while fetching AWS Batch jobs")
        return jsonify({"success": False, "error": "Request timed out after 2 minutes"}), 504
    except Exception as e:
        logger.error(f"Error fetching AWS Batch jobs: {e}", exc_info=True)
        return jsonify({"success": False, "error": str(e)}), 500


@app.route("/picker/api/guess-config-names", methods=["POST"])