Dispatch based on bench method

src/worker/run.rs

@@ -1,3 +1,6 @@
+mod internal;
+mod repo;
+
 use std::{
     collections::HashMap,
     sync::{Arc, Mutex},
@@ -5,6 +8,7 @@ use std::{
 
 use time::OffsetDateTime;
 use tokio::sync::mpsc;
+use tracing::{debug_span, error, Instrument};
 
 use crate::{
     id,
@@ -89,5 +93,16 @@ pub async fn run(
     abort_rx: mpsc::UnboundedReceiver<()>,
     bench_method: BenchMethod,
 ) {
-    // TODO Implement
+    async {
+        let result = match bench_method {
+            BenchMethod::Internal => internal::run(run, abort_rx).await,
+            BenchMethod::Repo { hash } => repo::run(run, hash, abort_rx).await,
+        };
+        match result {
+            Ok(()) => {}
+            Err(e) => error!("Error during run:\n{e:?}"),
+        }
+    }
+    .instrument(debug_span!("run"))
+    .await;
 }

src/worker/run/internal.rs

@@ -0,0 +1,14 @@
+use std::sync::{Arc, Mutex};
+
+use tokio::sync::mpsc;
+
+use crate::somehow;
+
+use super::Run;
+
+pub async fn run(
+    run: Arc<Mutex<Run>>,
+    abort_rx: mpsc::UnboundedReceiver<()>,
+) -> somehow::Result<()> {
+    todo!()
+}

src/worker/run/repo.rs

@@ -0,0 +1,15 @@
+use std::sync::{Arc, Mutex};
+
+use tokio::sync::mpsc;
+
+use crate::somehow;
+
+use super::Run;
+
+pub async fn run(
+    run: Arc<Mutex<Run>>,
+    hash: String,
+    abort_rx: mpsc::UnboundedReceiver<()>,
+) -> somehow::Result<()> {
+    todo!()
+}