fix: execute local future correctly

docs/docs/ai/llm.mdx

@@ -52,7 +52,7 @@ It has the following fields:
 
 Embedding means converting text into a vector space, usually for similarity matching.
 
-We provide a builtin function [`EmbedText`](/docs/ops/functions#embedtext) that converts a given text into a vector space. 
+We provide a builtin function [`EmbedText`](/docs/ops/functions#embedtext) that converts a given text into a vector space.
 The spec takes the following fields:
 
 *   `api_type` (type: `cocoindex.LlmApiType`, required)

docs/docs/ops/functions.md

@@ -133,4 +133,3 @@ Input data:
 *   `text` (type: `str`, required): The text to embed.
 
 Return type: `vector[float32; N]`, where `N` is the dimension of the embedding vector determined by the model.
-

docs/sidebars.ts

@@ -61,4 +61,4 @@ const sidebars: SidebarsConfig = {
   ],
 };
 
-export default sidebars;
+export default sidebars;

src/builder/flow_builder.rs

@@ -3,6 +3,7 @@ use crate::{prelude::*, py::Pythonized};
 use pyo3::{exceptions::PyException, prelude::*};
 use pyo3_async_runtimes::tokio::future_into_py;
 use std::{collections::btree_map, ops::Deref};
+use tokio::task::LocalSet;
 
 use super::analyzer::{
     AnalyzerContext, CollectorBuilder, DataScopeBuilder, OpScope, build_flow_instance_context,
@@ -622,14 +623,17 @@ impl FlowBuilder {
         };
         let py_ctx = crate::py::PythonExecutionContext::new(py, py_event_loop);
 
-        future_into_py(py, async move {
-            let analyzed_flow = tokio::task::spawn_local(
+        let analyzed_flow = get_runtime().spawn_blocking(|| {
+            let local_set = LocalSet::new();
+            local_set.block_on(
+                get_runtime(),
                 super::AnalyzedTransientFlow::from_transient_flow(spec, Some(py_ctx)),
             )
-            .await
-            .into_py_result()?
-            .into_py_result()?;
-            Ok(py::TransientFlow(Arc::new(analyzed_flow)))
+        });
+        future_into_py(py, async move {
+            Ok(py::TransientFlow(Arc::new(
+                analyzed_flow.await.into_py_result()?.into_py_result()?,
+            )))
         })
     }