CostEstimator

Package: flyte.extras

Protocol for records that can estimate their own processing cost.

Implement this on your record type and the batcher will call it
automatically when no explicit `estimated_cost` is passed to
`DynamicBatcher.submit`.

Example::

    @dataclass
    class ApiRequest:
        payload: str

        def estimate_cost(self) -> int:
            return len(self.payload)

protocol CostEstimator()

Methods

estimate_cost()

def estimate_cost()