nat.front_ends.fastapi.fastapi_front_end_plugin#

Attributes#

logger

Classes#

FastApiFrontEndPlugin

Module Contents#

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

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

_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()#