Function run_executor

src/executor/mod.rs:156–226

Run a single executor: setup → run → teardown → persist logs. Does NOT upload.

(
    executor: &mut dyn Executor,
    orchestrator: &Orchestrator,
    execution_context: &ExecutionContext,
    setup_cache_dir: Option<&Path>,
    rolling_buffer_label: Option<&str>,
)

/// Run a single executor: setup → run → teardown → persist logs.
/// Does NOT upload.
pub async fn run_executor(
    executor: &mut dyn Executor,
    orchestrator: &Orchestrator,
    execution_context: &ExecutionContext,
    setup_cache_dir: Option<&Path>,
    rolling_buffer_label: Option<&str>,
) -> Result<()> {
    match executor.support_level(&orchestrator.system_info) {
        ExecutorSupport::Unsupported => {
            bail!(
                "The {} executor is not supported on {}",
                executor.name(),
                orchestrator.system_info.os
            );
        }
        ExecutorSupport::RequiresManualInstallation | ExecutorSupport::FullySupported => {
            if !execution_context.config.skip_setup {
                executor
                    .setup(&orchestrator.system_info, setup_cache_dir)
                    .await?;
                executor.grant_privileges()?;
            }
        }
    }

    if !execution_context.config.skip_setup {
        // TODO: refactor and move directly in the Instruments struct as a `setup` method
        if execution_context.config.instruments.is_mongodb_enabled() {
            install_mongodb_tracer().await?;
        }

        debug!("Environment ready");
    }

    if !execution_context.config.skip_run {
        // TODO: refactor and move directly in the Instruments struct as a `start` method
        let mongo_tracer =
            if let Some(mongodb_config) = &execution_context.config.instruments.mongodb {
                let mut mongo_tracer =
                    MongoTracer::try_from(&execution_context.profile_folder, mongodb_config)?;
                mongo_tracer.start().await?;
                Some(mongo_tracer)
            } else {
                None
            };

        if let Some(label) = rolling_buffer_label {
            activate_rolling_buffer(label);
        }
        let run_result = executor.run(execution_context, &mongo_tracer).await;
        if rolling_buffer_label.is_some() {
            deactivate_rolling_buffer();
        }
        run_result?;

        // TODO: refactor and move directly in the Instruments struct as a `stop` method
        if let Some(mut mongo_tracer) = mongo_tracer {
            mongo_tracer.stop().await?;