app/services/aggregator/factoryAggr.py
class FactoryAggr(object):
def __init__(self, dataframe, type):
self._dataframe = dataframe
self._type = type
def run(self, cls):
field = cls.getField()
if field in self._dataframe:
try:
df = self._dataframe[field]
cls.execute(df, self._type)
return cls.getResult()
except IndexError:
return {}