Struct TaskApplication 

pub struct TaskApplication { /* private fields */ }

The POST /v1/tasks Application — resolves a BlueprintRef and runs it to completion through TaskLaunchService.

Implementations

impl TaskApplication

pub fn new( launch: Arc<TaskLaunchService>, store: Arc<dyn BlueprintStore>, ) -> Self

Build a TaskApplication that can resolve both Inline and Id BlueprintRefs (the Id path reads through store).

pub fn new_inline_only(launch: Arc<TaskLaunchService>) -> Self

Build a TaskApplication restricted to Inline BlueprintRefs — no store is configured, so Id resolution always fails with TaskApplicationError::NoStore.

pub async fn resolve( &self, bp_ref: &BlueprintRef, ) -> Result<(Blueprint, Option<BlueprintVersion>), TaskApplicationError>

Resolve a BlueprintRef and return the real Blueprint plus, when it went through the store, the resolved version.

pub async fn handle_with_run( &self, input: TaskApplicationInput, run_ctx: Option<RunContext>, ) -> Result<TaskApplicationOutput, TaskApplicationError>

Resolve the BlueprintRef (Inline / Id) and run the flow to completion through TaskLaunchService::launch, threading run_ctx (issue #13 run_id propagation) into the launch input.

Application::handle delegates here with run_ctx: None — a separate method rather than a new field on TaskApplicationInput so the pre-existing exhaustive TaskApplicationInput { .. } struct literal in mlua-swarm-cli’s MCP adapter (which has no run_ctx) keeps compiling unchanged. Server entry points that mint a RunId up front (POST /v1/tasks, POST /v1/tasks/:id/runs) call this directly with Some(run_ctx).

Trait Implementations

impl Application for TaskApplication

fn handle<'life0, 'async_trait>( &'life0 self, input: Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resolve the BlueprintRef (Inline / Id) and run the flow to completion through TaskLaunchService::launch. Delegates to TaskApplication::handle_with_run with run_ctx: None (no run tracing) — callers that need RunRecord.step_entries tracing call handle_with_run directly instead.

type Input = TaskApplicationInput

The request type this Application accepts.

type Output = TaskApplicationOutput

The result type returned on success.

type Error = TaskApplicationError

The error type returned on failure.

fn name(&self) -> &str

A short identifier for this Application instance (used in logs and diagnostics).