diff --git a/src/utils/agents/data-collector.py b/src/utils/agents/data-collector.py index 230162e..2704d5d 100644 --- a/src/utils/agents/data-collector.py +++ b/src/utils/agents/data-collector.py @@ -88,7 +88,10 @@ class ICollector(Thread) : else: label = id row = data - + # + # At this point we should check for the status and if it prompts an action + # @TODO Use a design pattern for this ... + # self.lock.acquire() store = self.factory.instance(type=write_class,args=read_args) store.flush(size=200)