Merge branch 'master' into improve-doc

OpenCyphal · Jan 8, 2024 · 157cb3e · 157cb3e
2 parents 5f7b3f6 + eddd2b3
commit 157cb3e
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 8 deletions.
diff --git a/pycyphal/_version.py b/pycyphal/_version.py
@@ -1 +1 @@
-__version__ = "1.17.0"
+__version__ = "1.17.1"
diff --git a/tests/__init__.py b/tests/__init__.py
@@ -64,4 +64,5 @@ def doctest_await(future: Awaitable[_T]) -> _T:
     This is a hack; when the proper solution is available it should be removed:
     https://github.com/Erotemic/xdoctest/issues/115
     """
+    asyncio.get_event_loop().slow_callback_duration = max(asyncio.get_event_loop().slow_callback_duration, 10.0)
     return asyncio.get_event_loop().run_until_complete(future)
diff --git a/tests/presentation/subscription_synchronizer/monotonic_clustering.py b/tests/presentation/subscription_synchronizer/monotonic_clustering.py
@@ -58,45 +58,45 @@ def ts() -> SynchronizedTimestamp_1:
     await pub_a.publish(force.Scalar_1(ts(), reference))
     await pub_b.publish(power.Scalar_1(ts(), reference))
     await pub_c.publish(angle.Scalar_1(ts(), reference))
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(1.0)
     assert 1 == cb_count
 
     reference += 1
     await pub_c.publish(angle.Scalar_1(ts(), reference))  # Reordered.
     await pub_b.publish(power.Scalar_1(ts(), reference))
     await pub_a.publish(force.Scalar_1(ts(), reference))
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(1.0)
     assert 2 == cb_count
 
     reference += 1
     await pub_b.publish(power.Scalar_1(ts(), 999999999))  # Incorrect, will be overridden next.
     await pub_b.publish(power.Scalar_1(ts(), reference))  # Override the incorrect value.
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(1.0)
     await pub_a.publish(force.Scalar_1(ts(), reference))
     await pub_c.publish(angle.Scalar_1(ts(), reference))
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(1.0)
     assert 3 == cb_count
 
     reference += 1
     await pub_a.publish(force.Scalar_1(ts(), reference))
     # b skip
     await pub_c.publish(angle.Scalar_1(ts(), reference))
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(1.0)
     assert 3 == cb_count
 
     reference += 1
     # a skip
     await pub_b.publish(power.Scalar_1(ts(), reference))
     await pub_c.publish(angle.Scalar_1(ts(), reference))
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(1.0)
     assert 3 == cb_count
 
     for i in range(10):
         reference += 1
         await pub_a.publish(force.Scalar_1(ts(), reference))
         await pub_b.publish(power.Scalar_1(ts(), reference))
         await pub_c.publish(angle.Scalar_1(ts(), reference))
-        await asyncio.sleep(0.1)
+        await asyncio.sleep(1.0)
         assert 4 + i == cb_count
 
     pres.close()