Some work by Rafael

product/CMFActivity/Activity/SQLJoblib.py

@@ -26,9 +26,9 @@
 #
 ##############################################################################
 
-from SQLQueue import SQLQueue
+from SQLDict import SQLDict
 
-class SQLJoblib(SQLQueue):
+class SQLJoblib(SQLDict):
   """
     XXX SQLJoblib
   """

product/CMFActivity/__init__.py

@@ -40,7 +40,7 @@ document_classes = updateGlobals(this_module, globals(),
 # Finish installation
 def initialize( context ):
   # Define object classes and tools
-  import ActivityTool, ActiveProcess, ActivityConnection
+  import ActivityTool, ActiveProcess, ActivityConnection, ActivityJoblibBackend
   object_classes = (ActiveProcess.ActiveProcess,
                     #ActivityConnection.ActivityConnection
                     )

product/ERP5Type/ZopePatch.py

@@ -87,6 +87,7 @@ from Products.ERP5Type.patches import CMFCoreUtils
 from Products.ERP5Type.patches import ZopePageTemplate
 from Products.ERP5Type.patches import ZSQLMethod
 from Products.ERP5Type.patches import MimetypesRegistry
+from Products.ERP5Type.patches import JoblibParallelPrint
 
 # These symbols are required for backward compatibility
 from Products.ERP5Type.patches.PropertyManager import ERP5PropertyManager

product/ERP5Type/patches/JoblibParallelPrint.py

+
+ENABLE_PATCH = True
+try:
+  import sklearn
+  #from sklearn.externals import joblib
+  #from sklearn.externals.joblib.parallel import Parallel
+  from joblib.parallel import Parallel
+except ImportError:
+  ENABLE_PATCH = False
+
+if ENABLE_PATCH:
+  from zLOG import LOG, WARNING
+
+  def _print(self, msg, msg_args):    
+    msg = msg % msg_args    
+    LOG('Parallel._print', WARNING, '[%s]: %s\n' % (self, msg))  
+
+
+  Parallel._print = _print