Merge pull request #158 from we-lsp/reduce_logs

feat: 精简错误日志

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "atomic-bomb-engine-py"
-version = "0.41.1"
+version = "0.41.2"
 edition = "2021"
 
 [lib]
@@ -10,7 +10,7 @@ crate-type = ["cdylib"]
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-atomic-bomb-engine = "0.41.0"
+atomic-bomb-engine = "0.41.1"
 #atomic-bomb-engine = { git = "https://github.com/we-lsp/atomic-bomb-engine.git", branch = "ExponentialMovingAverage"}
 tokio = "1.36.0"
 pyo3-asyncio = { version = "0.20.0", features = ["tokio-runtime", "async-std"] }

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "maturin"
 
 [project]
 name = "atomic_bomb_engine"
-version = "0.41.1"
+version = "0.41.2"
 description = "使用rust开发的高性能python压测工具"
 license = "MIT"
 readme = "README.md"

src/py_lib/batch_runner.rs

@@ -115,7 +115,6 @@ impl BatchRunner {
 
                 match next_stream {
                     Some(Ok(result)) => {
-
                         if result.is_none() {
                             let done = slf.is_done.clone();
                             slf.runtime.block_on(async {
@@ -180,7 +179,7 @@ impl BatchRunner {
                             *done_lock = true;
                         });
                         Ok(None)
-                    },
+                    }
                 }
             }
             None => {