def __init__(self, worker_id, publish_func, args):
        """
        :param args: Array of arrays. Defines which values to return at consequent process calls. For example,
        args = [[], [1], [12, 13]] will result in process not generating any results in the first call, generating '1'
        in the second and '12', '13' at the third invocation of 'process'
        """
        super(PreprogrammedReturnValueWorker, self).__init__(worker_id, publish_func, args)
        self._program = args
        self._current_step = 0

        :param args: Array of arrays. Defines which values to return at consequent process calls. For example,
        args = [[], [1], [12, 13]] will result in process not generating any results in the first call, generating '1'
        in the second and '12', '13' at the third invocation of 'process'
        
petastorm/workers_pool/tests/stub_workers.py