Method submit

dask/local.py:577–583

(self, fn, *args, **kwargs)

    _max_workers = 1

    def submit(self, fn, *args, **kwargs):
        fut = Future()
        try:
            fut.set_result(fn(*args, **kwargs))
        except BaseException as e:  # noqa: B036
            fut.set_exception(e)
        return fut


synchronous_executor = SynchronousExecutor()