9 releases (1 stable)
1.0.0 | Jul 20, 2024 |
---|---|
0.1.7 | Mar 15, 2024 |
0.1.5 | Feb 25, 2024 |
0.1.4 | Oct 1, 2023 |
0.1.1 | Aug 23, 2023 |
#22 in #orchestration
190KB
5K
SLoC
Astro Run Remote Runner
astro-run-remote-runner
is an extension of astro-run that allows runners to act as remote services and lets astro-run
act as a client to connect via gRPC requests. The remote runner streams runtime logs, events, etc. to the client using streams.
Example
Add astro-run
and astro-run-remote-runner
as dependencies in your Cargo.toml
:
[dependencies]
astro-run = "0.1"
astro-run-remote-runner = "0.1"
Remote Runner Server
use astro_run::{stream, Context, Result, RunResult};
use astro_run_remote_runner::AstroRunRemoteRunnerServer;
// Simulated implementation of a Runner
struct Runner {}
impl Runner {
fn new() -> Self {
Runner {}
}
}
#[astro_run::async_trait]
impl astro_run::Runner for Runner {
async fn run(&self, ctx: Context) -> astro_run::RunResponse {
let (tx, rx) = stream();
tx.log(ctx.command.run);
tx.end(RunResult::Succeeded);
Ok(rx)
}
}
#[tokio::main]
async fn main() -> Result<()> {
let runner = Runner::new();
let runner_server = AstroRunRemoteRunnerServer::builder()
.runner(runner)
.build()
.unwrap();
runner_server.serve("127.0.0.1:5002").await.unwrap();
Ok(())
}
Astro-Run Client
use astro_run::{AstroRun, Result, Workflow};
use astro_run_remote_runner::AstroRunRemoteRunnerClient;
#[tokio::main]
async fn main() -> Result<()> {
let client_runner = AstroRunRemoteRunnerClient::builder().build().unwrap();
let handle = tokio::task::spawn({
let mut client_runner = client_runner.clone();
async move {
// Run the client runner in background
client_runner
.start(vec!["http://127.0.0.1:5002"])
.await
.unwrap();
}
});
let astro_run = AstroRun::builder().runner(client_runner).build();
let workflow = r#"
jobs:
job-id:
steps:
- run: Hello World
"#;
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;
// Wait for the client runner to finish
handle.await.unwrap();
Ok(())
}
In the above example, you can replace the runner with a specific implementation from astro-runner.
Dependencies
~14–31MB
~491K SLoC