try this

Author: scottgerring

opentelemetry-otlp/tests/integration_test/src/test_utils.rs

@@ -128,24 +128,22 @@ fn upsert_empty_file(path: &str) -> File {
 /// suite shutting down!
 ///
 pub fn stop_collector_container() {
-    // This is a bit heinous. We get called after tokio has shutdown, but testcontainers
-    // needs an async runtime to shutdown, so we create a temporary new one just for this
-    // purpose.
+    // This is a bit heinous. We don't have an async runtime left when
+    // we hit this call, so we can't use the async methods on the testcontainers
+    // interface to shutdown.
+    // We _need_ to do this here, because otherwise we have no "all the tests in the module
+    // were complete" hook.
+    //
     // https://github.com/testcontainers/testcontainers-rs/issues/707
     otel_debug!(name: "stop_collector_container");
-    tokio::runtime::Runtime::new()
-        .unwrap()
-        .block_on(stop_it())
-        .expect("Couldn't create runtime to shutdown");
-}
 
-async fn stop_it() -> Result<()> {
-    if let Some(container) = COLLECTOR_ARC
-        .get()
-        .and_then(|arc_lock| arc_lock.lock().unwrap().take())
-    {
-        container.stop().await?;
-        otel_debug!(name: "stop_collector_container::stopped");
+    if let Some(mutex_option_arc) = COLLECTOR_ARC.get() {
+        let guard = mutex_option_arc.lock().unwrap();
+        if let Some(container_arc) = &*guard {
+            std::process::Command::new("docker")
+                .args(["container", "rm", "-f", container_arc.id()])
+                .output()
+                .expect("failed to stop testcontainer");
+        }
     }
-    Ok(())
 }