|
36 | 36 | import com.google.devtools.build.lib.events.Reporter;
|
37 | 37 | import com.google.devtools.build.lib.profiler.Profiler;
|
38 | 38 | import com.google.devtools.build.lib.profiler.SilentCloseable;
|
39 |
| -import com.google.devtools.build.lib.remote.common.CacheNotFoundException; |
40 |
| -import com.google.devtools.build.lib.remote.common.LostInputsEvent; |
41 | 39 | import com.google.devtools.build.lib.remote.common.RemoteActionExecutionContext;
|
42 | 40 | import com.google.devtools.build.lib.remote.common.RemoteCacheClient;
|
43 | 41 | import com.google.devtools.build.lib.remote.merkletree.MerkleTree;
|
@@ -185,19 +183,7 @@ private ListenableFuture<Void> uploadBlob(
|
185 | 183 | return cacheProtocol.uploadBlob(context, digest, file.getBytes());
|
186 | 184 | }
|
187 | 185 |
|
188 |
| - var path = checkNotNull(file.getPath()); |
189 |
| - try { |
190 |
| - if (remotePathChecker.isRemote(context, path)) { |
191 |
| - // If we get here, the remote input was determined to exist in the remote or disk cache at |
192 |
| - // some point before action execution, but reported to be missing when querying the remote |
193 |
| - // for missing action inputs; possibly because it was evicted in the interim. |
194 |
| - reporter.post(new LostInputsEvent(digest)); |
195 |
| - throw new CacheNotFoundException(digest, path.getPathString()); |
196 |
| - } |
197 |
| - } catch (IOException e) { |
198 |
| - return immediateFailedFuture(e); |
199 |
| - } |
200 |
| - return cacheProtocol.uploadFile(context, digest, path); |
| 186 | + return cacheProtocol.uploadFile(context, digest, file.getPath()); |
201 | 187 | }
|
202 | 188 |
|
203 | 189 | Message message = additionalInputs.get(digest);
|
|
0 commit comments