PiCloud to concurrent.futures API mapping

picloud_futures.py

from concurrent.futures import _base
import cloud

class PiCloudExecutor(_base.Executor):
    def __init__(self, max_workers):
        """Initializes a new PiCloudExecutor instance."""
        pass

    def submit(self, fn, *args, **kwargs):
        f = _base.Future()

        # make the call to the cloud
        jid = cloud.call(fn,*args,**kwargs)

        return f

    submit.__doc__ = _base.Executor.submit.__doc__

    def map(self, fn, *iterables):
        # will call cloud.map()   
        pass

    def shutdown(self, wait=True):

        pass

    shutdown.__doc__ = _base.Executor.shutdown.__doc__