From 1a860ac47b23efd1f32e8fa5b61ee8d1e2aa6c21 Mon Sep 17 00:00:00 2001 From: Pranesh Pandurangan Date: Fri, 13 Jun 2014 01:28:19 -0700 Subject: [PATCH] Refactor and add a check around a variable Changed serializer to self._serializer, to be able to access it from other places in the engine class. Added a check to make sure it doesn't get created twice. Change-Id: Ia4007a5f98af04677b2006a88b66cbf8ceec2982 --- entropy/engine.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/entropy/engine.py b/entropy/engine.py index de72ae6..cb571cc 100644 --- a/entropy/engine.py +++ b/entropy/engine.py @@ -77,6 +77,9 @@ class Engine(object): # Watchdog-related variables self._watchdog_thread = None + # Serializer related variables + self._serializer = None + LOG.info('Created engine obj %s', self.name) # TODO(praneshp): Move to utils? @@ -106,8 +109,9 @@ class Engine(object): self.start_scheduler() def start_scheduler(self): - serializer = self.executor.submit(self.start_serializer) - self.futures.append(serializer) + if not self._serializer: + self._serializer = self.executor.submit(self.start_serializer) + self.futures.append(self._serializer) # Start react scripts. self.futures.extend(self.start_react_scripts())