MCPcopy Create free account
hub / github.com/NVIDIA-NeMo/Switchyard / create_run_task

Method create_run_task

crates/libsy/src/core/algorithm.rs:954–973  ·  view source on GitHub ↗
(
            self: Arc<Self>,
            ctx: Context,
            driver: Driver,
            request: Request,
        )

Source from the content-addressed store, hash-verified

952 }
953
954 async fn create_run_task(
955 self: Arc<Self>,
956 ctx: Context,
957 driver: Driver,
958 request: Request,
959 ) -> Result<Response> {
960 let target = self
961 .target_set
962 .targets()
963 .first()
964 .ok_or(LibsyError::NoTargets)?
965 .clone();
966 let decision: Arc<dyn Decision> = Arc::new(TestDecision {
967 model: target.semantic_name.clone(),
968 });
969 driver.info(ctx.clone(), decision.clone()).await?;
970 driver
971 .call_llm_target(ctx, &target, request, decision)
972 .await
973 }
974 }
975
976 /// Build a shared `TestAlgo` over the given target set.

Callers 1

run_streamMethod · 0.45

Calls 6

DropGuardClass · 0.85
call_llm_targetMethod · 0.80
targetsMethod · 0.45
infoMethod · 0.45
sendMethod · 0.45
mapMethod · 0.45

Tested by

no test coverage detected