The helpers.parallel_add() was updated to be able to leverage the changes in v1.2.2. The generator function, process_q_item, now needs to yield a tuple. First element is either a Dict[bytes, int] representing the keys and their associated number of times to add them to the sketch or just an Iterable[bytes]. **NOTE** Using Dict is likely faster, but is data dependent. The second element is an int that is the number of records processed. This is so the count-min and heavy hitters sketches can record the number of records processed, as they did before.