nat.front_ends.fastapi.fastapi_front_end_plugin#

Attributes#

Classes#

FastApiFrontEndPlugin

Helper class that provides a standard way to create an ABC using

Module Contents#

logger#

class FastApiFrontEndPlugin(full_config: nat.data_models.config.Config)#

Bases: nat.front_ends.fastapi.dask_client_mixin.DaskClientMixin, nat.builder.front_end.FrontEndBase[nat.front_ends.fastapi.fastapi_front_end_config.FastApiFrontEndConfig]

Helper class that provides a standard way to create an ABC using inheritance.

Initializes the FrontEndBase object with the specified NAT configuration.

Parameters#

full_configConfig: The configuration object to use for the front end.

_cluster = None#

_periodic_cleanup_future = None#

_scheduler_address = None#

_use_dask_threads = False#

get_worker_class() → type[nat.front_ends.fastapi.fastapi_front_end_plugin_worker.FastApiFrontEndPluginWorkerBase]#

get_worker_class_name() → str#

async _submit_cleanup_task( scheduler_address: str, db_url: str, log_level: int = logging.INFO, )#: Submit a cleanup task to the cluster to remove the job after expiry.

async run()#: Runs the specified configuration file, launching the workflow until the front end is complete.