Alain Takoudjou · @alain.takoudjou · Alain Takoudjou · Alain Takoudjou · Thomas Gambier · Alain Takoudjou
--- a/slapos/grid/promise/__init__.py
+++ b/slapos/grid/promise/__init__.py
  """

  def __init__(self, partition_folder, promise_name, promise_path, argument_dict,
-      logger, allow_bang=True, uid=None, gid=None, wrap=False, 
-      check_anomaly=False):
+      logger, queue, allow_bang=True, wrap=False, check_anomaly=False):
--- a/slapos/grid/promise/__init__.py
+++ b/slapos/grid/promise/__init__.py
  def getPromiseTitle(self):
    return os.path.splitext(self.name)[0]

+  def updatePromiseCache(self, promise_class, promise_instance):
+    """
+      Cache some data from the promise that can be reused
+    """
+    py_file = '%s.py' % os.path.splitext(inspect.getfile(promise_class))[0]
--- a/slapos/grid/promise/__init__.py
+++ b/slapos/grid/promise/__init__.py
+    """
+      Cache some data from the promise that can be reused
+    """
+    py_file = '%s.py' % os.path.splitext(inspect.getfile(promise_class))[0]
+    stat = os.stat(py_file)
+    cache_dict = dict(
+      is_tested= not hasattr(promise_instance, 'isTested') or \
+          promise_instance.isTested(),
+      is_anomaly_detected=not hasattr(promise_instance, 'isAnomalyDetected') or \
+          promise_instance.isAnomalyDetected(),
+      periodicity=promise_instance.getPeriodicity(),
+      module_file=py_file,
+      module_file_mtime=stat.st_mtime,
+      module_file_size=stat.st_size,
+    )
+    if not os.path.isdir(self.cache_folder):
--- a/slapos/grid/promise/__init__.py
+++ b/slapos/grid/promise/__init__.py
                           key, extra_dict))
        self.argument_dict[key] = extra_dict[key]

+
+class PromiseWorker(Process):
--- a/slapos/grid/promise/__init__.py
+++ b/slapos/grid/promise/__init__.py
+    )
+    if not os.path.isdir(self.cache_folder):
+      mkdir_p(self.cache_folder)
+    with open(self.cache_file, 'w') as f:
+      f.write(json.dumps(cache_dict))
+
+  def loadPromiseCacheDict(self):
+    if os.path.exists(self.cache_file):
+      try:
+        with open(self.cache_file) as f:
+          cache_dict = json.loads(f.read())
+          if not os.path.exists(cache_dict['module_file']):
+            # file not exists mean path was changed
+            return None
+          current_stat = os.stat(cache_dict['module_file'])
+          if current_stat.st_mtime != cache_dict['module_file_mtime'] or \
--- a/slapos/grid/promise/__init__.py
+++ b/slapos/grid/promise/__init__.py
-      Save the promise execution timestamp
+      Load cached data for this promise.
+      If saved promise module file is not exists then invalidate cache.
+      Cache will be updated when promise run
    """
-    state_directory = os.path.dirname(self._timestamp_file)
-    mkdir_p(state_directory)
-    with open(self._timestamp_file, 'w') as f:
-      f.write(str(time.time()))
-
-  def getPromiseTitle(self):
-    return os.path.splitext(self.name)[0]
+    if os.path.exists(self.cache_file):
+      try:
+        with open(self.cache_file) as f:
+          cache_dict = json.loads(f.read())
--- a/slapos/tests/test_promise.py
+++ b/slapos/tests/test_promise.py

    self.launcher = PromiseLauncher(
      config=parameter_dict,
-      logger=logging.getLogger('slapos.test.promise'),
+      #logger=logging.getLogger('slapos.test.promise'),