Class DummyWorkerQueue

tests/splitwise/test_splitwise_connector.py:64–73

class DummyWorkerQueue:
    def __init__(self) -> None:
        self.cache_info_calls: List[List[Dict[str, Any]]] = []
        self.disaggregated_calls: List[Any] = []

    def put_cache_info(self, cache_info: List[Dict[str, Any]]) -> None:
        self.cache_info_calls.append(cache_info)

    def put_disaggregated_tasks(self, payload: Any) -> None:
        self.disaggregated_calls.append(payload)


class DummyTask: