Nuno Campos 92da3505d3 Implement new semantics for OUT topic ...

- The first message published to OUT ends the computation
- .invoke() returns a single value or None
- .stream() returns iterator of log entries, including the final OUT entry, if any
- Remove .peek() method

2023-09-19 14:09:59 +01:00

..

__init__.py

Move prefix management to Connection, Add Connection.peek(), Add test for resuming ongoing execution

2023-09-12 15:40:17 +01:00

connection_inmemory.py

Implement new semantics for OUT topic

2023-09-19 14:09:59 +01:00

connection.py

Implement new semantics for OUT topic

2023-09-19 14:09:59 +01:00

constants.py

Update for latest langchain, start to implement isolation and batch

2023-08-18 12:30:55 +01:00

pubsub.py

Implement new semantics for OUT topic

2023-09-19 14:09:59 +01:00

topic.py

Lint

2023-09-19 12:44:37 +01:00