Local Store: Complete tasks when resolving promises (#297)

* Local Store: Complete tasks when resolving promises

* add uv lock

* fix formatting

* only complete invoke and resume tasks

* first complete tasks. then callbacks

* first complete tasks. then callbacks

* complete notify tasks

Author: Tomperez98

resonate/stores/local.py

@@ -523,6 +523,12 @@ def transition(
                     return promise, task, applied
 
         if applied and promise.state in ("RESOLVED", "REJECTED", "REJECTED_CANCELED", "REJECTED_TIMEDOUT"):
+            # complete all pending tasks for the same promise_id
+            for task in self._store.tasks.scan():
+                if task.root_promise_id == id and task.state in ("INIT", "ENQUEUED", "CLAIMED"):
+                    _, applied = self._store.tasks.transition(task.id, "COMPLETED", force=True)
+                    assert applied
+
             # create resume and notify tasks
             for callback in promise.callbacks.values():
                 _, applied = self._store.tasks.transition(
@@ -536,6 +542,8 @@ def transition(
                 assert applied
             promise.callbacks.clear()
 
+
+
         return promise, None, applied
 
     def _transition(

resonate/stores/remote.py

@@ -87,7 +87,7 @@ def call(self, req: PreparedRequest) -> Any:
                     if delay is None or e.response.status_code != 500:
                         mesg = error.get("message", "Unknown exception")
                         code = error.get("code", 0)
-                        details = error.get("details", None)
+                        details = error.get("details")
                         raise ResonateStoreError(mesg=mesg, code=code, details=details) from e
                 except requests.exceptions.Timeout as e:
                     if delay is None: