#!/usr/bin/env python # coding: utf-8 # In[1]: import sys get_ipython().system('{sys.executable} -m pip list') # In[2]: import ipyparallel as ipp rc = ipp.Client() # In[3]: view = rc.load_balanced_view() # In[4]: import os import glob directory_location = os.path.join(os.getcwd(), "*") class inputobject(object): filepath = None inputlist = [] x = 0 for image in glob.glob(directory_location): obj = inputobject() obj.filepath = image inputlist.append(obj) # In[5]: view.map_async(lambda obj: obj.filepath, inputlist[x:x+100], ordered=False).get() # In[6]: rc[:].use_cloudpickle() # In[7]: view.map_async(lambda obj: obj.filepath, inputlist[x:x+100], ordered=False).get()