from abc import ABC


class TaskConsumerWrapper(ABC):
    def __init__(self, *args, **kwargs):
        pass

    def initialize_callable(self, consumer_concurrency: int):
        pass

    def __del__(self):
        pass