plynx.utils.executor

Utils to work with executors

Module Contents

plynx.utils.executor.CONNECT_POST_TIMEOUT = 1.0

plynx.utils.executor.REQUESTS_TIMEOUT = 10

plynx.utils.executor.urljoin(base: str, postfix: str) → str

Join urls in a reasonable way

plynx.utils.executor.post_request(uri, data, num_retries=3)

Make post request to the url

plynx.utils.executor._update_node(node: plynx.db.node.Node)

Update node in the database

plynx.utils.executor.materialize_executor(node: Union[Dict[str, Any], plynx.db.node.Node]) → BaseExecutor

Create a Node object from a dictionary

Parameters:

node: dictionary representation of a Node or the node itself

Returns:

Executor: Executor based on the kind of the Node and the config

class plynx.utils.executor.TickThread(executor: BaseExecutor)

This class is a Context Manager wrapper. It calls method tick() of the executor with a given interval

TICK_TIMEOUT :int = 1

__enter__(self)

Currently no meaning of returned class

__exit__(self, type_cls, value, traceback_val)

call_executor_tick(self)

Run timed ticks

class plynx.utils.executor.DBJobExecutor(executor: BaseExecutor)

Executes a single job in an executor and updates its status.

run(self)

Run the job in the executor

kill(self)

Kill the running job