|
|
@ -51,8 +51,8 @@ class Learner(Process):
|
|
|
|
self._encoder = None
|
|
|
|
self._encoder = None
|
|
|
|
self._map = None
|
|
|
|
self._map = None
|
|
|
|
self._df = _args['data'] if 'data' in _args else None
|
|
|
|
self._df = _args['data'] if 'data' in _args else None
|
|
|
|
self.name = self.__class__.__name__+'::'+self.info['from']
|
|
|
|
self.name = self.__class__.__name__
|
|
|
|
self.name = self.name.replace('?','')
|
|
|
|
|
|
|
|
#
|
|
|
|
#
|
|
|
|
# @TODO: allow for verbose mode so we have a sens of what is going on within the newtork
|
|
|
|
# @TODO: allow for verbose mode so we have a sens of what is going on within the newtork
|
|
|
|
#
|
|
|
|
#
|
|
|
@ -64,7 +64,7 @@ class Learner(Process):
|
|
|
|
# sel.max_epoc
|
|
|
|
# sel.max_epoc
|
|
|
|
def log(self,**_args):
|
|
|
|
def log(self,**_args):
|
|
|
|
logger = transport.factory.instance(**self.store['logger']) if 'logger' in self.store else transport.factory.instance(provider='console',context='write',lock=True)
|
|
|
|
logger = transport.factory.instance(**self.store['logger']) if 'logger' in self.store else transport.factory.instance(provider='console',context='write',lock=True)
|
|
|
|
_args = dict({'ndx':self.ndx,'module':self.name,'info':self.info['context'],**_args})
|
|
|
|
_args = dict({'ndx':self.ndx,'module':self.name,'table':self.info['from'],'info':self.info['context'],**_args})
|
|
|
|
logger.write(_args)
|
|
|
|
logger.write(_args)
|
|
|
|
self.ndx += 1
|
|
|
|
self.ndx += 1
|
|
|
|
if hasattr(logger,'close') :
|
|
|
|
if hasattr(logger,'close') :
|
|
|
|