swale 0.2.0

A scheduled asset-graph orchestrator on object storage.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! `swale publish`.

use std::path::Path;
use std::process::ExitCode;
use std::sync::Arc;

use swale::OperatorSet;

use super::CommandResult;
use super::store::{StoreArg, create_store};

pub(crate) async fn publish(file: &Path, store: StoreArg) -> CommandResult {
    let text = std::fs::read_to_string(file)?;
    let store = create_store(store)?;
    let definitions = store.definitions(Arc::new(OperatorSet::builtin()));
    let published = definitions.publish(&text).await?;
    let state = if published.changed {
        "published"
    } else {
        "unchanged"
    };
    println!("{}: {state} {}", published.graph.name(), published.hash);
    Ok(ExitCode::SUCCESS)
}