A standard executor for DAGs.
Module Contents
-
plynx.plugins.executors.dag._WAIT_STATUS_BEFORE_FAILED[source]
-
plynx.plugins.executors.dag._ACTIVE_WAITING_TO_STOP[source]
-
plynx.plugins.executors.dag.node_cache_manager()[source]
Lazy NodeCacheManager definition
-
class
plynx.plugins.executors.dag.DAG(node: Node)[source]
Bases: plynx.plugins.executors.bases.PLynxAsyncExecutor
Main graph scheduler.
- Args:
- node (Node)
-
IS_GRAPH = True[source]
-
GRAPH_ITERATION_SLEEP = 1[source]
-
finished(self)[source]
Return True or False depending on the running status of the DAG.
-
pop_jobs(self)[source]
Get a set of nodes with satisfied dependencies
-
update_node(self, node: Node)[source]
Update node_running_status and outputs if the state has changed.
-
_set_node_status(self, node_id: ObjectId, node_running_status: str)[source]
-
static
_cacheable(node: Node)[source]
-
classmethod
get_default_node(cls, is_workflow: bool)[source]
-
_execute_node(self, node: Node)[source]
-
run(self, preview: bool = False)[source]
-
kill(self)[source]
Force to kill the process.
The reason can be the fact it was working too long or parent exectuter canceled it.
-
validate(self, ignore_inputs: bool = True)[source]