(self, *args, **kwargs)
Entry point for the aggregator.
Entry point for the aggregator.
Entry point for the aggregator .
def run(self, *args, **kwargs):
        """Entry point for the aggregator."""
        raise NotImplementedError
def run ( self , * args , * * kwargs ) : raise NotImplementedError