CO - polishing bug fix

community
Steve L. Nyemba 7 years ago
parent a5f9e0f516
commit 6ba4f52c35

@ -245,6 +245,7 @@ def InitCollector():
r = [] r = []
manager={} manager={}
try: try:
key = request.headers['key'] key = request.headers['key']
node= request.headers['id'] node= request.headers['id']
#scope=request.headers['scope'] if 'scope' in request.headers else {} #scope=request.headers['scope'] if 'scope' in request.headers else {}
@ -267,9 +268,11 @@ def InitCollector():
agent.init(args) agent.init(args)
lagents.append(agent) lagents.append(agent)
if id in a : if id in a :
actor = eval(a[id]+"()") #-- This variable should not be confused with defined namespace
lactors.append(actor)
_actor = eval(a[id]+"()")
lactors.append(_actor)
config = dict(CONFIG) config = dict(CONFIG)
# #
@ -512,3 +515,4 @@ if __name__== '__main__':
SYS_ARGS.PARAMS['port'] = 8484 SYS_ARGS.PARAMS['port'] = 8484
PORT = int(SYS_ARGS.PARAMS['port']) PORT = int(SYS_ARGS.PARAMS['port'])
app.run(host='0.0.0.0' ,port=PORT,debug=True,threaded=True) app.run(host='0.0.0.0' ,port=PORT,debug=True,threaded=True)

@ -175,6 +175,8 @@ class Mailer (Actor):
class Folders(Actor): class Folders(Actor):
def __init__(self):
Actor.__init__(self)
""" """
This is designed to handle folders i.e cleaning/archiving the folders This is designed to handle folders i.e cleaning/archiving the folders
if the user does NOT have any keys to cloud-view than she will not be able to archive if the user does NOT have any keys to cloud-view than she will not be able to archive
@ -187,7 +189,7 @@ class Folders(Actor):
#self.lfolders = args['folders'] #config['folders'] #self.lfolders = args['folders'] #config['folders']
#self.action = args['action'] #{clear,archive} config['actions']['folders'] #self.action = args['action'] #{clear,archive} config['actions']['folders']
self.threshold = self.get_size( args['threshold']) #self.config['threshold']) self.threshold = self.get_size( args['threshold']) #self.config['threshold'])
self.item = item self.item = args['folders']
def archive(self,item): def archive(self,item):
""" """

Loading…
Cancel
Save