arunpandianp opened a new pull request, #38592: URL: https://github.com/apache/beam/pull/38592
`ExecutableWork.run()` now returns a `WorkResult` which informs BoundedQueueExecutor how many items and bytes to decrement from the budgets. In future, an executing work may pull in more work from BoundedQueueExecutor and execute them in the same bundle. When that happens the returned WorkResult will be the sum of all Work executed in the bundle. -- 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]
