temp bugfix: for some reason, async traits don't seem to handle futur…

…es in impls correctly.

the error seems to be because the runtime environment is not accessible/out of scope

turbolift_internals/src/kubernetes.rs

@@ -218,7 +218,10 @@ impl DistributionPlatform for K8s {
         let service_base_url = self.fn_names_to_services.get(function_name).unwrap();
         let args = "./".to_string() + function_name + "/" + &params;
         let query_url = service_base_url.join(&args)?;
-        let response = self.get(query_url).await?;
+
+        let mut rt = tokio::runtime::Runtime::new().unwrap();
+        let response = rt.block_on(self.get(query_url))?;
+        // ^ todo find out why this code errors if we don't spawn another runtime here
         Ok(response)
     }
 

turbolift_internals/src/local_queue.rs

@@ -96,7 +96,10 @@ impl DistributionPlatform for LocalQueue {
         // request from server
         let prefixed_params = "./".to_string() + function_name + "/" + &params;
         let query_url = address_and_port.join(&prefixed_params)?;
-        let response = Self::get(query_url).await;
+
+        let mut rt = tokio::runtime::Runtime::new().unwrap();
+        let response = rt.block_on(Self::get(query_url));
+        // ^ todo find out why this code errors if we don't spawn another runtime here
         Ok(response)
     }