top lvl rfi lfi (#84)

* rename run to lfi. add lfc

* plain resolve promise and dedup on it's own method

* never as default retry policy

* Define API for top lvl rfi

* RFI only through commands

* resolve and pop

* resolve promise to resolve ephemeral promise

* dedup first step

* Add create with callback method to trait

* Use create promise + callback endpoint

* Implement trigger

* Add trigger

* Only recv and root promise if needed

Author: Tomperez98

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "resonate-sdk"
-version = "0.2.2"
+version = "0.2.3"
 description = "Distributed Async Await by Resonate HQ, Inc"
 authors = [
     { name = "Resonate HQ, Inc", email = "[email protected]" }

src/resonate/collections.py

@@ -42,7 +42,10 @@ def waiting_for(
         assert_never(awaiting_for)
 
     def append(
-        self, key: Promise[Any], value: ResonateCoro[Any], awaiting_for: AwaitingFor
+        self,
+        key: Promise[Any],
+        value: ResonateCoro[Any] | None,
+        awaiting_for: AwaitingFor,
     ) -> None:
         awaiting: dict[Promise[Any], list[ResonateCoro[Any]]]
         if awaiting_for == "local":
@@ -51,7 +54,11 @@ def append(
             awaiting = self._remote
         else:
             assert_never(awaiting_for)
-        awaiting.setdefault(key, []).append(value)
+        if value is not None:
+            awaiting.setdefault(key, []).append(value)
+        else:
+            assert key not in awaiting
+            awaiting[key] = []
 
     def get(
         self, key: Promise[Any], awaiting_for: AwaitingFor

src/resonate/retry_policy.py

@@ -88,7 +88,7 @@ def never() -> Never:
 
 
 def default_policy() -> RetryPolicy:
-    return exponential(base_delay=1, factor=2, max_retries=5)
+    return never()
 
 
 def calculate_total_possible_delay(policy: Exponential | Linear | Constant) -> float: