wenjin272 commented on issue #1016: URL: https://github.com/apache/flink-agents/issues/1016#issuecomment-5679538811
@pltbkd Thanks, this is a valid concern. After further discussion, we plan to make Java support the same compositional model, tracked in #1122. `durableExecuteAsync` would return a runtime-managed `DurableFuture`, while `ctx.await()` would yield the Continuation instead of blocking: ```java var first = ctx.durableExecuteAsync(call1); var second = ctx.durableExecuteAsync(call2); var outcomes = ctx.await(ctx.gather(List.of(first, second))); ``` Regarding lazy execution, I agree that it should be an explicit contract. Initially, both Java and Python handles can remain deferred: `gather` first reserves all pending slots and then submits the batch, preserving the reserve-before-execute guarantee from #926. Supporting eager submission later would require a separate reservation design. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
