plynx.plugins.executors.bases

Executors supporting PLynx sync/async inference framework

Module Contents

plynx.plugins.executors.bases.run_cancellation_manager()

Lazy RunCancellationManager object

class plynx.plugins.executors.bases.PLynxAsyncExecutor

Bases: plynx.base.executor.BaseExecutor

Base Executor class that is using PLynx Async Inference backend

launch(self)

Put the Node on the queue

kill(self)

get_running_status(self)

Returns the status of the execution.

Async executions should sync with the remote and return the result immediately.

class plynx.plugins.executors.bases.PLynxSyncExecutor

Bases: plynx.base.executor.BaseExecutor

Base Executor class that is using PLynx Sync Inference backend

launch(self)

Run the node now and return the status

class plynx.plugins.executors.bases.PLynxAsyncExecutorWithDirectory(node)

Bases: plynx.plugins.executors.bases.PLynxAsyncExecutor

Base Executor class that is using PLynx Async Inference backend

init_executor(self)

Make tmp dir if it does not exist

clean_up_executor(self)

Remove tmp dir