repo_description: Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
repo_topics: batch-processing data-analytics data-pipelines data-processing dataflow etl etl-framework iot-analytics kafka machine-learning-algorithms pathway python real-time rust stream-processing streaming time-series-analysis
code: use std::io;
  
  use tokio::runtime::Runtime as TokioRuntime;
  
  pub fn create_async_tokio_runtime() -> Result<TokioRuntime, io::Error> {
      tokio::runtime::Builder::new_current_thread()
          .enable_all()
          .build()
  }
  