Timeout, updated test-r, external epoch loop

Cargo.toml

@@ -188,7 +188,7 @@ testcontainers-modules = { version = "0.11.4", features = [
     "redis",
     "minio",
 ] }
-test-r = { version = "2.0.1", default-features = true }
+test-r = { version = "2.1.0", default-features = true }
 thiserror = "2.0.6"
 tokio = { version = "1.42", features = [
     "macros",

golem-worker-executor-base/src/lib.rs

@@ -99,6 +99,7 @@ const VERSION: &str = golem_version!();
 pub struct RunDetails {
     pub http_port: u16,
     pub grpc_port: u16,
+    pub epoch_thread: std::thread::JoinHandle<()>,
 }
 
 /// The Bootstrap trait should be implemented by all Worker Executors to customize the initialization
@@ -249,12 +250,11 @@ pub trait Bootstrap<Ctx: WorkerCtx> {
 
         let lazy_worker_activator = Arc::new(LazyWorkerActivator::new());
 
-        let worker_executor_impl = create_worker_executor_impl::<Ctx, Self>(
+        let (worker_executor_impl, epoch_thread) = create_worker_executor_impl::<Ctx, Self>(
             golem_config.clone(),
             self,
             runtime.clone(),
             &lazy_worker_activator,
-            join_set,
         )
         .await?;
 
@@ -272,6 +272,7 @@ pub trait Bootstrap<Ctx: WorkerCtx> {
         Ok(RunDetails {
             http_port,
             grpc_port: addr.port(),
+            epoch_thread,
         })
     }
 }
@@ -281,8 +282,7 @@ async fn create_worker_executor_impl<Ctx: WorkerCtx, A: Bootstrap<Ctx> + ?Sized>
     bootstrap: &A,
     runtime: Handle,
     lazy_worker_activator: &Arc<LazyWorkerActivator<Ctx>>,
-    join_set: &mut JoinSet<Result<(), anyhow::Error>>,
-) -> Result<All<Ctx>, anyhow::Error> {
+) -> Result<(All<Ctx>, std::thread::JoinHandle<()>), anyhow::Error> {
     let (redis, sqlite, key_value_storage): (
         Option<RedisPool>,
         Option<SqlitePool>,
@@ -473,17 +473,13 @@ async fn create_worker_executor_impl<Ctx: WorkerCtx, A: Bootstrap<Ctx> + ?Sized>
     let engine = Arc::new(Engine::new(&config)?);
     let linker = bootstrap.create_wasmtime_linker(&engine)?;
 
-    let mut epoch_interval = tokio::time::interval(golem_config.limits.epoch_interval);
     let engine_ref: Arc<Engine> = engine.clone();
-    join_set.spawn(
-        async move {
-            loop {
-                epoch_interval.tick().await;
-                engine_ref.increment_epoch();
-            }
-        }
-        .in_current_span(),
-    );
+
+    let epoch_interval = golem_config.limits.epoch_interval;
+    let epoch_thread = std::thread::spawn(move || loop {
+        std::thread::sleep(epoch_interval);
+        engine_ref.increment_epoch();
+    });
 
     let linker = Arc::new(linker);
 
@@ -539,7 +535,7 @@ async fn create_worker_executor_impl<Ctx: WorkerCtx, A: Bootstrap<Ctx> + ?Sized>
         golem_config.scheduler.refresh_interval,
     );
 
-    bootstrap
+    let all = bootstrap
         .create_services(
             active_workers,
             engine,
@@ -564,5 +560,7 @@ async fn create_worker_executor_impl<Ctx: WorkerCtx, A: Bootstrap<Ctx> + ?Sized>
             plugins,
             oplog_processor_plugin,
         )
-        .await
+        .await?;
+
+    Ok((all, epoch_thread))
 }

golem-worker-executor-base/tests/guest_languages2.rs

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use test_r::{inherit_test_dep, test};
+use test_r::{inherit_test_dep, test, timeout};
 
 use crate::common::{start, TestContext};
 use crate::{LastUniqueId, Tracing, WorkerExecutorTestDependencies};
@@ -28,6 +28,7 @@ inherit_test_dep!(Tracing);
 
 #[test]
 #[tracing::instrument]
+#[timeout(180_000)]
 async fn javascript_example_3(
     last_unique_id: &LastUniqueId,
     deps: &WorkerExecutorTestDependencies,