Struct CustomNode 

pub struct CustomNode {

    pub path: String,
    pub source: NodeSource,
    pub path_sha256: Option<String>,
    pub args: Option<String>,
    pub envs: Option<BTreeMap<String, EnvValue>>,
    pub build: Option<String>,
    pub send_stdout_as: Option<String>,
    pub send_logs_as: Option<String>,
    pub min_log_level: Option<String>,
    pub max_log_size: Option<String>,
    pub max_rotated_files: Option<u32>,
    pub restart_policy: RestartPolicy,
    pub max_restarts: u32,
    pub restart_delay: Option<f64>,
    pub max_restart_delay: Option<f64>,
    pub restart_window: Option<f64>,
    pub health_check_timeout: Option<f64>,
    pub finish_grace_secs: Option<f64>,
    pub run_config: NodeRunConfig,
}

Fields

path: String

Path of the source code

If you want to use a specific conda environment. Provide the python path within the source.

source: /home/peter/miniconda3/bin/python

args: some_node.py

Source can match any executable in PATH.

source: NodeSource

path_sha256: Option<String>

SHA-256 the path download must match (set for hub binary artifacts, spec §8.2). When present the daemon fetches path as a verified URL download regardless of confinement — the checksum is the trust anchor.

args: Option<String>

Args for the executable.

envs: Option<BTreeMap<String, EnvValue>>

Environment variables for the custom nodes

Deprecated, use outer-level env field instead.

build: Option<String>

send_stdout_as: Option<String>

Send stdout and stderr to another node

send_logs_as: Option<String>

Redirect structured log entries to a data output as JSON strings

min_log_level: Option<String>

Minimum log level for this node

max_log_size: Option<String>

Maximum log file size before rotation (e.g. “50MB”, “1GB”)

max_rotated_files: Option<u32>

Maximum number of rotated log files to keep (default: 5)

restart_policy: RestartPolicy

max_restarts: u32

Maximum number of restart attempts. 0 means unlimited.

restart_delay: Option<f64>

Initial delay in seconds before restarting (exponential backoff).

max_restart_delay: Option<f64>

Maximum delay in seconds for exponential backoff.

restart_window: Option<f64>

Time window in seconds for counting restarts.

health_check_timeout: Option<f64>

Health check timeout in seconds.

When set, the daemon monitors this node for activity. If the node does not communicate with the daemon within this timeout, it is killed and the restart policy is evaluated.

finish_grace_secs: Option<f64>

Per-node finish-drain grace period in seconds.

Overrides the global DORA_FINISH_DRAIN_GRACE_SECS for this node only.

run_config: NodeRunConfig

Trait Implementations

impl Clone for CustomNode

fn clone(&self) -> CustomNode

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CustomNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CustomNode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for CustomNode

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for CustomNode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.