Skip to content

chore: gracefully shutdown when error encountered #152

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

Merged
merged 17 commits into from
Nov 6, 2024

.

00a0429
Select commit
Loading
Failed to load commit list.
Merged

chore: gracefully shutdown when error encountered #152

.
00a0429
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Nov 6, 2024 in 1s

No report found to compare against

View this Pull Request on Codecov

No report found to compare against

Annotations

Check warning on line 66 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L66 

Added line #L66 was not covered by tests

Check warning on line 70 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L70 

Added line #L70 was not covered by tests

Check warning on line 89 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L88-L89 

Added lines #L88 - L89 were not covered by tests

Check warning on line 99 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L99 

Added line #L99 was not covered by tests

Check warning on line 111 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L109-L111 

Added lines #L109 - L111 were not covered by tests

Check warning on line 125 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L125 

Added line #L125 was not covered by tests

Check warning on line 127 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L127 

Added line #L127 was not covered by tests

Check warning on line 113 in src/main/java/io/numaproj/numaflow/batchmapper/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Service.java#L111-L113 

Added lines #L111 - L113 were not covered by tests

Check warning on line 116 in src/main/java/io/numaproj/numaflow/batchmapper/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Service.java#L115-L116 

Added lines #L115 - L116 were not covered by tests

Check warning on line 75 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-L75 

Added lines #L73 - L75 were not covered by tests

Check warning on line 80 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#L80 

Added line #L80 was not covered by tests

Check warning on line 121 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#L121 

Added line #L121 was not covered by tests

Check warning on line 126 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#L123-L126 

Added lines #L123 - L126 were not covered by tests

Check warning on line 128 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#L128 

Added line #L128 was not covered by tests

Check warning on line 145 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#L145 

Added line #L145 was 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 157 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#L156-L157 

Added lines #L156 - L157 were not covered by tests

Check warning on line 70 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L70 

Added line #L70 was not covered by tests

Check warning on line 74 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L74 

Added line #L74 was not covered by tests

Check warning on line 95 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L94-L95 

Added lines #L94 - L95 were not covered by tests

Check warning on line 98 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L98 

Added line #L98 was not covered by tests

Check warning on line 108 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L108 

Added line #L108 was not covered by tests

Check warning on line 112 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L112 

Added line #L112 was not covered by tests

Check warning on line 117 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L114-L117 

Added lines #L114 - L117 were not covered by tests

Check warning on line 124 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L120-L124 

Added lines #L120 - L124 were not covered by tests
View more details on Codecov