Source code for superduperdb.backends.local.compute

import typing as t
import uuid

from superduperdb import logging
from superduperdb.backends.base.compute import ComputeBackend

[docs] class LocalComputeBackend(ComputeBackend): """ A mockup backend for running jobs locally. """ def __init__( self, ): self.__outputs: t.Dict = {} @property def type(self) -> str: return "local" @property def name(self) -> str: return "local"
[docs] def submit( self, function: t.Callable, *args, compute_kwargs: t.Dict = {}, **kwargs ) -> str: """ Submits a function for local execution. :param function: The function to be executed. """"Submitting job. function:{function}") future = function(*args, **kwargs) future_key = str(uuid.uuid4()) self.__outputs[future_key] = future logging.success( f"Job submitted on {self}. function:{function} future:{future_key}" ) return future_key
@property def tasks(self) -> t.Dict[str, t.Any]: """ List for all pending tasks """ return self.__outputs
[docs] def wait_all(self) -> None: """ Waits for all pending tasks to complete. """ pass
[docs] def result(self, identifier: str) -> t.Any: """ Retrieves the result of a previously submitted task. Note: This will block until the future is completed. :param identifier: The identifier of the submitted task. """ return self.__outputs[identifier]
[docs] def disconnect(self) -> None: """ Disconnect the local client. """ pass
[docs] def shutdown(self) -> None: """ Shuts down the local cluster. """ pass