reverting changes

Signed-off-by: Ankur_Anand <Ankur.Anand@dell.com>

Author: AnkurAnand11

Cargo.toml

@@ -20,7 +20,6 @@ default = ["python_binding"]
 javascript_binding = ["wasm-bindgen"]
 python_binding = ["pyo3", "pyo3-asyncio"]
 
-
 #Run tests for bindings using command cargo test --no-default-features
 
 [dependencies]
@@ -42,7 +41,6 @@ derive-new = "0.5"
 #Python bindings
 pyo3 = { version = "0.14.5" ,optional = true }
 pyo3-asyncio = { version = "0.14", features = ["tokio-runtime"], optional = true }
-pyo3-log = "0.9.0"
 #WASM bindings
 wasm-bindgen = { version = "0.2.63", optional = true }
 cfg-if = "1.0.0"

src/lib.rs

@@ -48,7 +48,7 @@ cfg_if! {
 #[pymodule]
 /// A Python module for Pravega implemented in Rust.
 fn pravega_client(py: Python, m: &PyModule) -> PyResult<()> {
-    let _log = pyo3_log::init();
+    let _ = tracing_subscriber::fmt::try_init();
     m.add_class::<StreamManager>()?;
     m.add_class::<StreamWriter>()?;
     m.add_class::<StreamTxnWriter>()?;

tests/pravega_client_test.py

@@ -190,9 +190,6 @@ def test_byteStream(self):
         except Exception as e:
             print("Exception ", e)
 
-
-
-
     def test_writeTxn(self):
         scope = ''.join(secrets.choice(string.ascii_lowercase + string.digits)
                         for i in range(10))

tests/pravega_reader_test.py

@@ -47,7 +47,6 @@ async def test_writeEventAndRead(self):
         w1.flush()
         # Create a reader Group Configuration to read from HEAD of stream.
         rg_config = pravega_client.StreamReaderGroupConfig(False, scope, stream)
-
         reader_group=stream_manager.create_reader_group_with_config("rg" + suffix, scope, rg_config)
         r1 = reader_group.create_reader("reader-1")
         segment_slice = await r1.get_segment_slice_async()

tests/test.py

@@ -9,7 +9,7 @@ async def test_writeEventAndRead():
     scope = "testRead"
     stream = "testStream" + suffix
     print("Creating a Stream Manager, ensure Pravega is running")
-    stream_manager = pravega_client.StreamManager("tcp://127.0.0.1:9090")
+    stream_manager = pravega_client.StreamManager("127.0.0.1:9090")
 
     print("Creating a scope")
     scope_result = stream_manager.create_scope(scope)