process_img.py

import requests
from typing import Any, Dict, Iterable
from PIL import Image
from io import BytesIO

def transform_img(df: List[Dict[str, Any]]) -> Iterable[str, Any]:
    for row in df:
        try:
            response = requests.get(row["ImgUrl"], timeout=5)
            img = Image.open(BytesIO(response.content))
            xmin = float(row["xmin"]) * img.width
            xmax = float(row["xmax"]) * img.width
            ymin = float(row["ymin"]) * img.height
            ymax = float(row["ymax"]) * img.height
            img = img.crop((xmin, ymin, xmax, ymax))

            # logic to save image to cloud storage
            
            yield row
        except Exception as e:
            logger.error(e)
            yield row
            
  results = transform_img(df.to_dict("records"))