Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
Alexander Weber committed Jul 31, 2023
1 parent e7e9977 commit 112c360
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 9 deletions.
6 changes: 3 additions & 3 deletions docs/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -41,21 +41,21 @@ neomake workflow init -tpython
Now, execute the `count` node. Per default, `neomake` will only use exactly one worker thread and execute the endless embedded python program.

```bash
neomake plan -ccount | neomake x -fyaml
neomake plan -ccount | neomake x
```

In order to work on all 4 desired executions (defined as 2x2 matrix), call neomake with the number of worker threads desired. Now you will see that the 4 programs will be executed in parallel.

```bash
neomake plan -ccount | neomake x -fyaml -w4
neomake plan -ccount | neomake x -w4
```

## Graph execution

Execute nodes as follows.

```bash
neomake plan -f ./test/.neomake.yaml -c bravo -c charlie -oyaml | neomake execute -fyaml
neomake plan -f ./test/.neomake.yaml -c bravo -c charlie -oron | neomake execute -fron
```

Nodes can define an array of dependenies (other nodes) that need to be executed beforehand. All node executions are deduplicated so that every node is only executed exactly once if requested for invocation or as a prerequisite on any level to any node that is to be executed. Alongside the ability to specify multiple node to be executed per command line call, this feature allows for complex workflows to be executed.\
Expand Down
8 changes: 3 additions & 5 deletions src/args.rs
Original file line number Diff line number Diff line change
@@ -1,16 +1,14 @@
use crate::{error::Error, plan::ExecutionPlan, workflow::Workflow};
use anyhow::Result;
use clap::{Arg, ArgAction};
use itertools::Itertools;
use std::{
collections::{HashMap, HashSet},
io::Read,
iter::FromIterator,
str::FromStr,
};

use clap::{Arg, ArgAction};
use itertools::Itertools;

use crate::{error::Error, plan::ExecutionPlan, workflow::Workflow};

#[derive(Debug, Eq, PartialEq)]
pub(crate) enum Privilege {
Normal,
Expand Down
1 change: 0 additions & 1 deletion src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ use crate::{compiler::Compiler, workflow::Workflow};
#[tokio::main]
async fn main() -> Result<()> {
let cmd = crate::args::ClapArgumentLoader::load()?;
cmd.validate()?;

match cmd.command {
| crate::args::Command::Manual { path, format } => {
Expand Down

0 comments on commit 112c360

Please sign in to comment.