8 releases (1 stable)
1.0.0 | Jul 20, 2024 |
---|---|
0.1.6 | Mar 15, 2024 |
0.1.4 | Oct 1, 2023 |
0.1.3 | Sep 10, 2023 |
0.1.1 | Aug 23, 2023 |
#20 in #grpc-server
34 downloads per month
Used in 2 crates
165KB
4.5K
SLoC
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:
[dependencies]
astro-run = "0.1"
Code Example
use astro_run::{stream, AstroRun, RunResult, Workflow};
struct Runner;
impl Runner {
fn new() -> Self {
Runner
}
}
#[astro_run::async_trait]
impl astro_run::Runner for Runner {
async fn run(&self, ctx: astro_run::Context) -> astro_run::RunResponse {
let (tx, rx) = stream();
tokio::task::spawn(async move {
// 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)
.await
.unwrap();
// Create a new execution context
let ctx = astro_run.execution_context().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.
Dependencies
~14–30MB
~495K SLoC