def submit(self, fn, *args, **kwargs):
        """ Internal """
        if not self.is_shutdown:
            return self.cluster.executor.submit(fn, *args, **kwargs)
def submit ( self , fn , * args , ** kwargs ) : if not self . is_shutdown : return self . cluster . executor . submit ( fn , * args , ** kwargs )
Internal