@@ -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