dst badge

.github/workflows/ci.yml

@@ -69,4 +69,5 @@ jobs:
       - name: run tests
         env:
           RESONATE_HOST: http://localhost
-        run: uv run pytest -s
+
+        run: uv run pytest --cov=resonate --no-cov-on-fail --cov-report term:skip-covered tests

.gitignore

@@ -15,3 +15,6 @@ wheels/
 .mypy_cache/
 .ruff_cache/
 .pytest_cache/
+
+# cov
+.coverage

README.md

@@ -6,6 +6,8 @@
 
 <div align="center">
 
+[![ci](https://github.com/resonatehq/resonate-sdk-py/actions/workflows/ci.yml/badge.svg)](https://github.com/resonatehq/resonate-sdk-py/actions/workflows/ci.yml)
+[![dst](https://github.com/resonatehq/resonate-sdk-py/actions/workflows/dst.yml/badge.svg)](https://github.com/resonatehq/resonate-sdk-py/actions/workflows/dst.yml)
 [![License](https://img.shields.io/badge/License-Apache_2.0-blue.svg)](https://opensource.org/licenses/Apache-2.0)
 
 </div>

pyproject.toml

@@ -20,6 +20,7 @@ build-backend = "hatchling.build"
 dev = [
     "pyright>=1.1.396",
     "pytest>=8.3.5",
+    "pytest-cov>=6.1.1",
     "ruff>=0.11.0",
     "types-requests>=2.32.0.20250306",
 ]

tests/test_resonate.py

@@ -199,7 +199,7 @@ def invoke_with_opts(id: str) -> Invoke:
     assert promise.ikey_for_create == "f1"
     assert promise.param.headers == {}  # TODO(dfarr): this should be None
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.2)
     assert promise.tags == {"resonate:invoke": default_opts.target, "resonate:scope": "global"}
 
     resonate.run("f2", name, *args, **kwargs)
@@ -210,8 +210,8 @@ def invoke_with_opts(id: str) -> Invoke:
     assert promise.ikey_for_create == "f2"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**default_conv.tags, "resonate:scope": "global"} == {"resonate:invoke": default_opts.target, "resonate:scope": "global"}
 
     resonate.options(**opts).run("f3", func, *args, **kwargs)
@@ -222,7 +222,7 @@ def invoke_with_opts(id: str) -> Invoke:
     assert promise.ikey_for_create == idempotency_key if idempotency_key else "f3"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.2)
     assert promise.tags == {**updated_opts.tags, "resonate:invoke": updated_opts.target, "resonate:scope": "global"}
 
     resonate.options(**opts).run("f4", name, *args, **kwargs)
@@ -233,8 +233,8 @@ def invoke_with_opts(id: str) -> Invoke:
     assert promise.ikey_for_create == idempotency_key if idempotency_key else "f4"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**updated_conv.tags, "resonate:scope": "global"} == {**updated_opts.tags, "resonate:invoke": updated_opts.target, "resonate:scope": "global"}
 
     f.run("f5", *args, **kwargs)
@@ -245,8 +245,8 @@ def invoke_with_opts(id: str) -> Invoke:
     assert promise.ikey_for_create == "f5"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**default_conv.tags, "resonate:scope": "global"} == {"resonate:invoke": default_opts.target, "resonate:scope": "global"}
 
     f.options(**opts).run("f6", *args, **kwargs)
@@ -257,8 +257,8 @@ def invoke_with_opts(id: str) -> Invoke:
     assert promise.ikey_for_create == idempotency_key if idempotency_key else "f6"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**updated_conv.tags, "resonate:scope": "global"} == {**updated_opts.tags, "resonate:invoke": updated_opts.target, "resonate:scope": "global"}
 
 
@@ -323,7 +323,7 @@ def test_rpc(
     assert promise.ikey_for_create == "f1"
     assert promise.param.headers == {}  # TODO(dfarr): this should be None
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.2)
     assert promise.tags == {"resonate:invoke": default_opts.target, "resonate:scope": "global"}
 
     resonate.rpc("f2", name, *args, **kwargs)
@@ -334,8 +334,8 @@ def test_rpc(
     assert promise.ikey_for_create == "f2"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**default_conv.tags, "resonate:scope": "global"} == {"resonate:invoke": default_opts.target, "resonate:scope": "global"}
 
     resonate.options(**opts).rpc("f3", func, *args, **kwargs)
@@ -346,7 +346,7 @@ def test_rpc(
     assert promise.ikey_for_create == idempotency_key if idempotency_key else "f3"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.2)
     assert promise.tags == {**updated_opts.tags, "resonate:invoke": updated_opts.target, "resonate:scope": "global"}
 
     resonate.options(**opts).rpc("f4", name, *args, **kwargs)
@@ -357,8 +357,8 @@ def test_rpc(
     assert promise.ikey_for_create == idempotency_key if idempotency_key else "f4"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**updated_conv.tags, "resonate:scope": "global"} == {**updated_opts.tags, "resonate:invoke": updated_opts.target, "resonate:scope": "global"}
 
     f.rpc("f5", *args, **kwargs)
@@ -369,8 +369,8 @@ def test_rpc(
     assert promise.ikey_for_create == "f5"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, default_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**default_conv.tags, "resonate:scope": "global"} == {"resonate:invoke": default_opts.target, "resonate:scope": "global"}
 
     f.options(**opts).rpc("f6", *args, **kwargs)
@@ -381,8 +381,8 @@ def test_rpc(
     assert promise.ikey_for_create == idempotency_key if idempotency_key else "f6"
     assert promise.param.headers == {}
     assert promise.param.data == {"func": name, "args": list(args), "kwargs": kwargs, "version": version or 1}
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.1)
-    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.1)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_opts.timeout, rel_tol=0.2)
+    assert math.isclose((promise.timeout - promise.created_on) / 1000, updated_conv.timeout, rel_tol=0.2)
     assert promise.tags == {**updated_conv.tags, "resonate:scope": "global"} == {**updated_opts.tags, "resonate:invoke": updated_opts.target, "resonate:scope": "global"}