"""Job Processors."""

from typing import Protocol

from backfill.connectors.ows_pdp.ows_pdp import OwsPdpClient


class MissingFileException(Exception):
    """Raise when the file being processed is missing."""

    pass


class JobProcessor(Protocol):
    """General interface for a class that processes a given JobType."""

    def process(
        self,
        csv_filepath: str,
        ows_pdp_client: OwsPdpClient,
        backfill_uuid: str,
    ) -> None:
        """Load the csv file and apply desired changes."""
        ...