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.

@dataclass
class ApiRequest:
    payload: str

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

protocol CostEstimator()

Methods

estimate_cost()

def estimate_cost()