

def _load_aggregates(self, conn):
    for (name, (klass, num_params)) in num_params._aggregates.items():

        def make_aggregate():
            instance = klass()
            return (instance, instance.step, instance.finalize)
        conn.createaggregatefunction(name, make_aggregate)

dataset/ETHPy150Open coleifer/peewee/playhouse/apsw_ext.py APSWDatabase._load_aggregates/VarMisuse@23/29 `self`->`num_params`