[{'Text': '            f"S3 copy_object failed from {source_bucket!r}/{source_key!r} "\n            f"to {SOURCES_BUCKET!r}/{dest_key!r}: {e}"\n        ) from e\n\n\ndef download_from_url(url: str) -> tuple[bytes, str]:\n    """Download file from HTTP(S) URL. Returns (body_bytes, content_type).\n\n    Raises RuntimeError on failure.\n    """\n    try:\n        with httpx.Client(timeout=120.0, follow_redirects=True) as client:\n            r = client.get(url)\n            r.raise_for_status()\n            ct = (\n                r.headers.get("content-type", "application/octet-stream")\n                .split(";")[0]\n                .strip()\n            )\n            return r.content, ct\n    except httpx.HTTPError as e:\n        raise RuntimeError(f"Failed to download from URL: {e}") from e\n\n\ndef _safe_filename(name: str) -> str:\n    base = name.replace("\\\\", "/").rsplit("/", 1)[-1] or "file"\n    base = re.sub(r"[^a-zA-Z0-9._-]+", "_", base).strip("_") or "file"\n    return base[:200]\n\n\ndef _object_https_url(*, bucket: str, key: str) -> str:\n    encoded = quote(key, safe="/")\n    return f"https://{bucket}.s3.{S3_REGION}.amazonaws.com/{encoded}"\n\n\ndef upload_to_sources_bucket(body: bytes, content_type: str, dest_key: str) -> str:\n    """Upload bytes to SOURCES_BUCKET. Returns permanent HTTPS URL."""\n    bucket = SOURCES_BUCKET\n    try:\n        cli = _client()\n        cli.put_object(\n            Bucket=bucket,\n            Key=dest_key,\n            Body=body,\n            ContentType=content_type,\n        )\n        return _object_https_url(bucket=bucket, key=dest_key)\n    except ClientError as e:\n        raise RuntimeError(f"S3 put_object failed bucket={bucket!r} key={dest_key!r}: {e}") from e\n\n\ndef build_sources_dest_key(\n    *,\n    operator_id: str,\n    year: int,\n    quarter: int,\n    original_filename: str,\n) -> str:\n    uid = uuid.uuid4().hex[:12]\n    safe = _safe_filename(original_filename)\n    return f"sources/{operator_id}/{year}Q{quarter}/{uid}_{safe}"\n'}]