Method upload_all

src/executor/orchestrator.rs:248–288

(
        &self,
        completed_runs: &mut [(ExecutionContext, ExecutorName)],
        api_client: &mut CodSpeedAPIClient,
    )

    }

    pub async fn upload_all(
        &self,
        completed_runs: &mut [(ExecutionContext, ExecutorName)],
        api_client: &mut CodSpeedAPIClient,
    ) -> Result<UploadResult> {
        let mut last_upload_result: Option<UploadResult> = None;

        let total_runs = completed_runs.len();
        for (run_part_index, (ctx, executor_name)) in completed_runs.iter_mut().enumerate() {
            // OIDC tokens can expire quickly, so refresh just before each upload
            self.provider.set_oidc_token(api_client).await?;

            if total_runs > 1 {
                info!("Uploading results {}/{total_runs}", run_part_index + 1);
            }
            let run_part_suffix =
                Self::build_run_part_suffix(executor_name, run_part_index, total_runs);
            let upload_result = upload(
                self,
                api_client,
                ctx,
                executor_name.clone(),
                run_part_suffix,
            )
            .await?;
            last_upload_result = Some(upload_result);
        }
        info!("Performance data uploaded");
        if let Some(upload_result) = &last_upload_result {
            info!(
                "Linked repository: {}",
                console::style(format!(
                    "{}/{}",
                    upload_result.owner, upload_result.repository
                ))
                .bold()
            );
        }

        last_upload_result.ok_or_else(|| anyhow::anyhow!("No completed runs to upload"))
    }
}