import requests from datetime import datetime def execute_job(job: dict) -> dict: url = job.get("target_url") method = job.get("method", "GET").upper() headers = job.get("headers", {}) or {} body = job.get("body", None) timeout = job.get("timeout_seconds", 30) start_time = datetime.utcnow() try: if method == "POST": response = requests.post(url, headers=headers, json=body, timeout=timeout) elif method == "PUT": response = requests.put(url, headers=headers, json=body, timeout=timeout) elif method == "DELETE": response = requests.delete(url, headers=headers, timeout=timeout) else: response = requests.get(url, headers=headers, timeout=timeout) elapsed = (datetime.utcnow() - start_time).total_seconds() return { "success": response.status_code < 400, "status_code": response.status_code, "response_time": elapsed, "error": None } except Exception as e: elapsed = (datetime.utcnow() - start_time).total_seconds() return { "success": False, "status_code": 0, "response_time": elapsed, "error": str(e) }