def __init__(self, config): super(ThreadPoolClient, self).__init__(config) self.pool = ThreadPool(processes=config['kinesis_concurrency'])