Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore: Map Stream to Support Concurrent Requests #160

Open
wants to merge 4 commits into
base: main
Choose a base branch
from
+442 −163

Merge branch 'main' into map-stream

f02c36c
Select commit
Loading
Failed to load commit list.
Open

chore: Map Stream to Support Concurrent Requests #160

Merge branch 'main' into map-stream
f02c36c
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Feb 6, 2025 in 0s

No report found to compare against

View this Pull Request on Codecov

No report found to compare against

Annotations

Check warning on line 76 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L73-L76 

Added lines #L73 - L76 were not covered by tests

Check warning on line 147 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L147 

Added line #L147 was not covered by tests

Check warning on line 88 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L77-L88 

Added lines #L77 - L88 were not covered by tests

Check warning on line 97 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L93-L97 

Added lines #L93 - L97 were not covered by tests

Check warning on line 102 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L101-L102 

Added lines #L101 - L102 were not covered by tests

Check warning on line 140 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L137-L140 

Added lines #L137 - L140 were not covered by tests

Check warning on line 144 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L142-L144 

Added lines #L142 - L144 were not covered by tests

Check warning on line 146 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L146 

Added line #L146 was not covered by tests

Check warning on line 164 in src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/MapStreamSupervisorActor.java#L159-L164 

Added lines #L159 - L164 were not covered by tests

Check warning on line 64 in src/main/java/io/numaproj/numaflow/mapstreamer/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Service.java#L64 

Added line #L64 was not covered by tests
View more details on Codecov