Merge branch 'master' into fix-partition-logs

faust-streaming · Jul 19, 2022 · 882c99a · 882c99a
2 parents 156b636 + 1e9d4a5
commit 882c99a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/bench/base.py b/tests/bench/base.py
@@ -94,7 +94,7 @@ async def produce(self, max_latency: float, max_messages: int, **kwargs):
                 time_start = monotonic()
                 time_1st = monotonic()
 
-                def on_published(meta):
+                def on_published(meta, time_1st=time_1st):
                     print(f"1ST OK: {meta} AFTER {monotonic() - time_1st}s")
 
                 callback = on_published