This won't work in the distributed setup anymore because we cannot assume that the ingress is colocated with all partition leaders. Instead, we need to enable the Ingress to lookup the leader for a given PartitionKey and then fetch the invocation output from it.
The
Ingress
has currently direct access to thePartitionStoreManager
and allPartitionStores
to read the invocation output: https://github.com/restatedev/restate/blob/3dc889771f3869e3e19a7f9beca4b1f85d991c4a/crates/worker/src/ingress_integration.rs#L43.This won't work in the distributed setup anymore because we cannot assume that the ingress is colocated with all partition leaders. Instead, we need to enable the
Ingress
to lookup the leader for a givenPartitionKey
and then fetch the invocation output from it.