+ pbenv

pipelet/pbenv.py

+from pipelet.environment import *  
+import os 
+
+class PBEnvironment(Environment):
+    """
+    """
+
+    def __init__(self, w):
+        """
+        """
+
+         ## worker instance
+        self._worker = w
+        
+        ## segment input  
+        self.seg_input = w.task.task_input
+        
+        ## segment output
+        self.seg_output = []
+        
+        ## list of temporary files
+        self._tmpf   = []   
+        
+        ## logger instance  
+        self.logger = init_logger ("pipelet", self._get_log_file(), level=[])  
+        
+        ## list of param to save    
+        self.lst_par = []  
+        
+        ## list of param to expose
+        self.lst_tag = []    
+        
+        ## dictionnary with external dependencies version or revision number 
+        self.version = {"pipelet":pipelet.__version__}