Struct VanillaSpec 

pub struct VanillaSpec { /* private fields */ }

A vanilla operation: jobs with no input tables.

This is the shape for work that is not a transformation of a table — a side-car computation, a distributed process, a job that fetches its own input. Coordination between the jobs is the user’s problem; the cluster’s side of the bargain is keeping job_count of them running.

use ytsaurus_client::{VanillaSpec, VanillaTask};

let spec = VanillaSpec::new(
    VanillaTask::new("worker", "./my_job", 4)
        .with_local_file("//tmp/my_job")
        .with_outputs(["//tmp/results"]),
);

Implementations

impl VanillaSpec

pub fn new(task: VanillaTask) -> Self

An operation with one task.

pub fn with_task(self, task: VanillaTask) -> Self

Adds another task, of a different kind.

It needs a different name too — see VanillaSpec::duplicate_task.

pub fn duplicate_task(&self) -> Option<&str>

The name two tasks share, if any.

The spec keys its tasks by name, so two tasks called the same thing are one task: the later one replaces the earlier, and the operation quietly runs half the work it was handed — it completes, so nothing anywhere reports a problem. Client::start_vanilla checks this before sending the spec; check it here if you render the spec yourself with VanillaSpec::to_yson.

pub fn skiff_table_mismatch(&self) -> Option<String>

Describes a task whose Skiff output format does not match its outputs.

See MapSpec::skiff_table_mismatch for what an unchecked mismatch costs. Client::start_vanilla checks this before sending the spec.

pub fn with_raw(self, key: impl Into<String>, value: YsonValue) -> Self

Sets any spec field this builder does not model.

pub fn to_yson(&self) -> YsonValue

Renders the spec.

Trait Implementations

impl Clone for VanillaSpec

fn clone(&self) -> VanillaSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for VanillaSpec

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

Formats the value using the given formatter.