"""Get cloud transfer progress."""

import json
from typing import Any

import boto3

from video import config


def get_cloud_transfer_progress(workflow_job_id: int, filename: str) -> Any:
    """Get cloud transfer progress."""
    progress_data = (
        boto3.client("s3")
        .get_object(
            Bucket=config.VIDEO_BUCKET_NAME,
            Key="raw/{}/{}.progress.json".format(workflow_job_id, filename),
        )["Body"]
        .read()
    )

    return json.loads(progress_data)