From e2c3199b4997145b32fb0ed89224b29e126da276 Mon Sep 17 00:00:00 2001 From: steve Date: Wed, 5 Apr 2017 15:21:06 -0500 Subject: [PATCH] refactoring data-collection class --- src/utils/agents/data-collector.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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)