Testing if all release calls happen after short sleep

Author: Sushisource

tests/worker/test_worker.py

@@ -29,7 +29,7 @@
     WorkflowSlotInfo,
 )
 from temporalio.workflow import VersioningIntent
-from tests.helpers import new_worker, worker_versioning_enabled
+from tests.helpers import new_worker, worker_versioning_enabled, assert_eq_eventually
 
 
 def test_load_default_worker_binary_id():
@@ -422,6 +422,9 @@ def reserve_asserts(self, ctx):
         await wf1.signal(WaitOnSignalWorkflow.my_signal, "finish")
         await wf1.result()
 
+    async def releases() -> int:
+        return ss.releases
+    await assert_eq_eventually(ss.reserves, releases)
     assert ss.reserves == ss.releases
     # Two workflow tasks, one activity
     assert ss.used == 3