Skip to content

chore(perf): Avoid message cloning in Sink #10159

chore(perf): Avoid message cloning in Sink

chore(perf): Avoid message cloning in Sink #10159

Triggered via pull request February 6, 2026 05:16
Status Success
Total duration 33m 28s
Artifacts 2

ci.yaml

on: pull_request
Matrix: E2E Tests
Fit to window
Zoom out
Zoom in

Annotations

12 warnings
Unit Tests
unused import: `crate::app::store::cbstore::jetstream_store::JetStreamCallbackStore`
Unit Tests
unused import: `crate::app::router_with_auth`
Unit Tests
unused import: `crate::app::orchestrator::OrchestratorState`
Unit Tests
unused import: `crate::Settings`
Unit Tests
unused import: `super::*`
Unit Tests
struct `PanicFlatmapStream` is never constructed
Unit Tests
struct `PanicBatchMap` is never constructed
Unit Tests
struct `PanicCat` is never constructed
Unit Tests
struct `SimpleTransformerPanic` is never constructed
Unit Tests
unused import: `crate::message::ReadAck`
Unit Tests
Restore cache failed: Dependencies file is not found in /home/runner/work/numaflow/numaflow. Supported file pattern: go.sum

Artifacts

Produced during runtime
Name Size Digest
entrypoint-linux-amd64 Expired
609 KB
sha256:c80d6dbc36cf54cef9c5c3a042548ed9bfb48834422623c01c9f3a90e871e66c
numaflow-rs-linux-amd64 Expired
21.5 MB
sha256:b6db39f56d3bd1845ac374ef7824093a50a8d6d5c57e20f90b25db65277d7fb3