Fix formatting

Author: oteffahi

tests/test_timestamp_stack.py

@@ -66,12 +66,7 @@ def test_timestamp_instrumentation_builder():
     assert not instr2.is_instrumented(InterceptionPoint.RECEIVE)
 
     # Build with only route and receive
-    instr3 = (
-        TimestampInstrumentationBuilder()
-        .set_route(True)
-        .set_receive(True)
-        .build()
-    )
+    instr3 = TimestampInstrumentationBuilder().set_route(True).set_receive(True).build()
     assert not instr3.is_instrumented(InterceptionPoint.SEND)
     assert instr3.is_instrumented(InterceptionPoint.ROUTE)
     assert instr3.is_instrumented(InterceptionPoint.RECEIVE)
@@ -105,12 +100,7 @@ def sub_callback(sample: Sample):
     time.sleep(SLEEP)
 
     # Test with timestamp_instrumentation
-    instr = (
-        TimestampInstrumentationBuilder()
-        .set_send(True)
-        .set_receive(True)
-        .build()
-    )
+    instr = TimestampInstrumentationBuilder().set_send(True).set_receive(True).build()
     publisher.put(msg, timestamp_instrumentation=instr)
 
     time.sleep(SLEEP)
@@ -168,12 +158,7 @@ def sub_callback(sample: Sample):
     subscriber = peer02.declare_subscriber(keyexpr, sub_callback)
     time.sleep(SLEEP)
 
-    instr = (
-        TimestampInstrumentationBuilder()
-        .set_send(True)
-        .set_receive(True)
-        .build()
-    )
+    instr = TimestampInstrumentationBuilder().set_send(True).set_receive(True).build()
     peer01.put(keyexpr, msg, timestamp_instrumentation=instr)
 
     time.sleep(SLEEP)
@@ -199,12 +184,7 @@ def queryable_callback(query):
     queryable = peer01.declare_queryable(keyexpr, queryable_callback)
     time.sleep(SLEEP)
 
-    instr = (
-        TimestampInstrumentationBuilder()
-        .set_send(True)
-        .set_receive(True)
-        .build()
-    )
+    instr = TimestampInstrumentationBuilder().set_send(True).set_receive(True).build()
     replies = peer02.get(keyexpr, timestamp_instrumentation=instr)
     for reply in replies:
         sample = reply.ok
@@ -239,12 +219,7 @@ def sub_callback(sample: Sample):
     subscriber = peer02.declare_subscriber(keyexpr, sub_callback)
     time.sleep(SLEEP)
 
-    instr = (
-        TimestampInstrumentationBuilder()
-        .set_send(True)
-        .set_receive(True)
-        .build()
-    )
+    instr = TimestampInstrumentationBuilder().set_send(True).set_receive(True).build()
     publisher.delete(timestamp_instrumentation=instr)
 
     time.sleep(SLEEP)
@@ -274,12 +249,7 @@ def queryable_callback(query):
     querier = peer02.declare_querier(keyexpr)
     time.sleep(SLEEP)
 
-    instr = (
-        TimestampInstrumentationBuilder()
-        .set_send(True)
-        .set_receive(True)
-        .build()
-    )
+    instr = TimestampInstrumentationBuilder().set_send(True).set_receive(True).build()
     replies = querier.get(timestamp_instrumentation=instr)
     for reply in replies:
         sample = reply.ok
@@ -345,12 +315,7 @@ def sub_callback(sample: Sample):
     subscriber = peer02.declare_subscriber(keyexpr, sub_callback)
     time.sleep(SLEEP)
 
-    instr = (
-        TimestampInstrumentationBuilder()
-        .set_send(True)
-        .set_receive(True)
-        .build()
-    )
+    instr = TimestampInstrumentationBuilder().set_send(True).set_receive(True).build()
     publisher.put(msg, timestamp_instrumentation=instr)
 
     time.sleep(SLEEP)

zenoh/__init__.pyi

@@ -2415,7 +2415,9 @@ def init_log_from_env_or(level: str):
     If `RUST_LOG` is not set, then logging is set to the provided level."""
 
 def open(
-    config: Config, *, timestamp_callback: Callable[[TsStackContext], bytes] | None = None
+    config: Config,
+    *,
+    timestamp_callback: Callable[[TsStackContext], bytes] | None = None
 ) -> Session:
     """Open a zenoh :class:`zenoh.Session`.