update rust packages to latest (sparckles#298)

* update rust packages to latest

* fix clippy issues

* fix package version

Cargo.toml

@@ -14,27 +14,27 @@ name = "robyn"
 crate-type = ["cdylib", "rlib"]
 
 [dependencies.pyo3]
-version = "0.14.1"
+version = "0.17.2"
 features = ["extension-module"]
 
 [dependencies]
 tokio = { version = "1.7.0", features = ["full"] }
 dashmap = {git = "https://github.com/quake/dashmap", branch = "parking_lot", features = ["parking_lot"]}
-pyo3-asyncio = { version="0.14.0" , features = ["attributes", "tokio-runtime"] }
+pyo3-asyncio = { version="0.17.0" , features = ["attributes", "tokio-runtime"] }
 anyhow = "1.0.38"
 actix-web = "4.0.1"
 actix-files = "0.6.0"
 futures-util = "0.3.15"
-matchit = "0.4.3"
+matchit = "0.6.0"
 actix-http = "3.0.4"
 socket2 = { version = "0.4.1", features = ["all"] }
 actix = "0.13.0"
 actix-web-actors = "4.1.0"
-uuid = { version = "0.8", features = ["serde", "v4"] }
+uuid = { version = "1.2.1", features = ["serde", "v4"] }
 serde = "1.0.136"
 serde_json = "1.0.79"
 futures = "0.3.21"
-pyo3-log = "0.4.1"
+pyo3-log = "0.7.0"
 log = "0.4.17"
 
 [features]

src/executors/mod.rs

@@ -8,12 +8,11 @@ use std::collections::HashMap;
 use std::rc::Rc;
 use std::sync::Arc;
 
-
 use actix_web::HttpResponse;
-
-use actix_web::{ HttpRequest};
-use anyhow::{ Result};
+use actix_web::{http::Method, web, HttpRequest};
+use anyhow::{bail, Result};
 use log::{debug, info};
+use pyo3_asyncio::TaskLocals;
 // pyO3 module
 use crate::types::PyFunction;
 
@@ -306,7 +305,7 @@ pub async fn execute_http_function(
 
 pub async fn execute_event_handler(
     event_handler: Option<Arc<PyFunction>>,
-    event_loop: Arc<Py<PyAny>>,
+    task_locals: &TaskLocals,
 ) -> Result<(), Box<dyn std::error::Error>> {
     if let Some(handler) = event_handler {
         match &(*handler) {
@@ -322,8 +321,8 @@ pub async fn execute_event_handler(
                     debug!("Startup event handler async");
 
                     let coroutine = function.as_ref(py).call0().unwrap();
-                    pyo3_asyncio::into_future_with_loop((*event_loop).as_ref(py), coroutine)
-                        .unwrap()
+
+                    pyo3_asyncio::into_future_with_locals(task_locals, coroutine).unwrap()
                 });
                 future.await?;
             }