Astro run

Astro Run is a highly extensible runner that can execute any workflow.

Features

• Workflow runtime for Docker
• Support for gRPC server to coordinate multiple runner clients
• Support for connecting to remote runners

Example

Dependencies

Add the following to your Cargo.toml file:

toml [dependencies] astro-run = "0.1"

Code Example

```rust use astro_run::{stream, AstroRun, Context, RunResult, Workflow};

struct Runner;

impl Runner { fn new() -> Self { Runner } }

impl astrorun::Runner for Runner { fn run(&self, ctx: Context) -> astrorun::RunResponse { let (tx, rx) = stream();

// Send running log
tx.log(ctx.command.run);

// Send success log
tx.end(RunResult::Succeeded);

Ok(rx)

} }

[tokio::main]

async fn main() { // Create astro run let astro_run = AstroRun::builder().runner(Runner::new()).build();

// Workflow let workflow = r#" jobs: job: name: Job steps: - run: Hello World "#;

// Create workflow let workflow = Workflow::builder() .config(workflow) .build(&astro_run) .unwrap();

// Create a new execution context let ctx = astrorun.executioncontext().build();

// Run workflow let _res = workflow.run(ctx).await; } ```

Astro Run only defines the interface for Runners. Users can implement their own desired Runners, e.g., Docker runner.

More Examples

• Workflow runtime for Docker
• Astro Run Plugins
• Astro run gRPC Server
• gRPC Runner Client
• Remote Runner

Contributing

Contributions are welcome! Feel free to open issues or submit pull requests to improve the project.

License

This project is licensed under the MIT License.