#NEWLINE# def createAggregatorService( config ) : #NEWLINE# #INDENT# from carbon.conf import settings #NEWLINE# settings . RELAY_METHOD = 'consistent-hashing' #NEWLINE# root_service = createBaseService ( config , settings ) #NEWLINE# setupPipeline ( [ 'rewrite:pre' , 'aggregate' , 'rewrite:post' , 'relay' ] , root_service , settings ) #NEWLINE# setupReceivers ( root_service , settings ) #NEWLINE# return root_service