Skip to content

Commit 199d95c

Browse files
Update sink IT: expecting exception when sink doesn't exist (#2362)
1 parent 82fa63d commit 199d95c

1 file changed

Lines changed: 6 additions & 16 deletions

File tree

google-cloud-logging/src/test/java/com/google/cloud/logging/BaseSystemTest.java

Lines changed: 6 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -148,14 +148,9 @@ public void testUpdateNonExistingSink() {
148148
.setVersionFormat(SinkInfo.VersionFormat.V2)
149149
.build();
150150
assertNull(logging().getSink(name));
151-
Sink sink = logging().update(sinkInfo);
152-
assertEquals(name, sink.getName());
153-
assertEquals(SinkInfo.VersionFormat.V2, sink.getVersionFormat());
154-
assertEquals("severity>=ERROR", sink.getFilter());
155-
DatasetDestination datasetDestination = sink.getDestination();
156-
assertEquals(logging().getOptions().getProjectId(), datasetDestination.getProject());
157-
assertEquals("dataset", datasetDestination.getDataset());
158-
assertTrue(logging().deleteSink(name));
151+
thrown.expect(LoggingException.class);
152+
thrown.expectMessage("NOT_FOUND");
153+
logging().update(sinkInfo);
159154
}
160155

161156
@Test
@@ -166,14 +161,9 @@ public void testUpdateNonExistingSinkAsync() throws ExecutionException, Interrup
166161
.setVersionFormat(SinkInfo.VersionFormat.V2)
167162
.build();
168163
assertNull(logging().getSinkAsync(name).get());
169-
Sink sink = logging().updateAsync(sinkInfo).get();
170-
assertEquals(name, sink.getName());
171-
assertEquals(SinkInfo.VersionFormat.V2, sink.getVersionFormat());
172-
assertEquals("severity>=ERROR", sink.getFilter());
173-
DatasetDestination datasetDestination = sink.getDestination();
174-
assertEquals(logging().getOptions().getProjectId(), datasetDestination.getProject());
175-
assertEquals("dataset", datasetDestination.getDataset());
176-
assertTrue(logging().deleteSinkAsync(name).get());
164+
thrown.expect(ExecutionException.class);
165+
thrown.expectMessage("NOT_FOUND");
166+
logging().updateAsync(sinkInfo).get();
177167
}
178168

179169
@Test

0 commit comments

Comments
 (0)