The GitHub Actions job "Pull Requests" on pekko.git/feat/stream-zipwith-supervision has failed. Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run: f6df975e7485585da25e41c0f3f4b4d5edad584a / 虎鸣 <[email protected]> fix: add supervision strategy support for zipWith and zipWithN zipper functions Motivation: zipWith and zipWithN accepted user zipper/combiner functions but did not consult SupervisionStrategy. Zipper exceptions failed the stream unconditionally, even when Resume/Restart was configured. Modification: Add zipper exception supervision handling in both implementations: - ZipWith boilerplate template (all arities) - Graph.ZipWithN Stop fails the stage; Resume/Restart drop the failing zipped element and continue by pulling new inputs. Pending bookkeeping is updated on resumed/ restarted failures so the stage can satisfy the current downstream demand without stalling. Update Scala/Java API docs and operator docs (`zipWith.md`, `zipWithN.md`) to document supervision behavior for combiner function failures. Add directional tests in: - FlowZipWithSpec - GraphZipWithNSpec covering explicit Stop, default Stop, Resume, and Restart. Result: zipWith/zipWithN now honor ActorAttributes.SupervisionStrategy for zipper failures with deterministic regression coverage for dropped-element paths. Tests: - sbt "stream-tests/Test/testOnly org.apache.pekko.stream.scaladsl.FlowZipWithSpec org.apache.pekko.stream.scaladsl.GraphZipWithNSpec" -- 37/37 passed - sbt "stream/mimaReportBinaryIssues" -- clean - sbt "docs/paradox" -- passed References: Refs #3110 Report URL: https://github.com/apache/pekko/actions/runs/28168093548 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
