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:

toml [dependencies] astro-run = "0.1" astro-run-remote-runner = "0.1"

Remote Runner Server

```rust use astrorun::{stream, Context, Result, RunResult}; use astrorunremoterunner::AstroRunRemoteRunnerServer;

// Simulated implementation of a Runner struct Runner {}

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

impl astrorun::Runner for Runner { fn run(&self, ctx: Context) -> astrorun::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

```rust use astrorun::{AstroRun, Result, Workflow}; use astrorunremoterunner::AstroRunRemoteRunnerClient;

[tokio::main]

async fn main() -> Result<()> { let client_runner = AstroRunRemoteRunnerClient::builder() // Connect to remote runner service .url("http://127.0.0.1:5002") .build() .await .unwrap();

let cloned_client_runner = client_runner.clone();
tokio::task::spawn(async move {
    // Run the client runner in the background
    cloned_client_runner.start().await.unwrap();
});

let astro_run = AstroRun::builder().runner(client_runner).build();

let workflow = r#"
jobs:
    test:
        name: Test Job
        steps:
            - run: Hello World1
"#;

let workflow = Workflow::builder().config(workflow).build().unwrap();

// Create a new execution context
let ctx = astro_run.execution_context();

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

Ok(())

} ```

In the above example, you can replace the runner with a specific implementation from astro-runner.