From b146b0dd7e574ade7511d2591e26fbdf7fd752ec Mon Sep 17 00:00:00 2001 From: Nuno Campos Date: Mon, 16 Oct 2023 14:08:35 +0100 Subject: [PATCH] Update readme --- README.md | 6 +++--- examples/readme.py | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/README.md b/README.md index cf4a8750f..65aae7bce 100644 --- a/README.md +++ b/README.md @@ -15,14 +15,14 @@ grow_value = ( | Pregel.send_to(value=lambda x: x if len(x) < 10 else None) ) -pubsub = Pregel( +app = Pregel( grow_value, channels={"value": channels.LastValue[str]()}, input="value", output="value", ) -assert pubsub.invoke("a") == "aaaaaaaa" +assert app.invoke("a") == "aaaaaaaa" ``` @@ -33,7 +33,7 @@ Check `examples` for more examples. - [x] Iterate on API - [x] do we want api to receive output from multiple channels in invoke() - [x] do we want api to send input to multiple channels in invoke() - - [ ] Finish updating tests to new API + - [x] Finish updating tests to new API - [ ] Implement input_schema and output_schema in Pregel - [ ] Implement checkpointing - [ ] Save checkpoints at end of each step diff --git a/examples/readme.py b/examples/readme.py index 3bb54429b..95f60fc7a 100644 --- a/examples/readme.py +++ b/examples/readme.py @@ -6,11 +6,11 @@ grow_value = ( | Pregel.send_to(value=lambda x: x if len(x) < 10 else None) ) -pubsub = Pregel( +app = Pregel( grow_value, channels={"value": channels.LastValue[str]()}, input="value", output="value", ) -assert pubsub.invoke("a") == "aaaaaaaa" +assert app.invoke("a") == "aaaaaaaa"