remotetool: add command to upload a tree into the CAS#287
remotetool: add command to upload a tree into the CAS#287Yannic wants to merge 1 commit intobazelbuild:masterfrom
Conversation
| if _, _, err := c.GrpcClient.UploadIfMissing(ctx, ue); err != nil { | ||
| // UploadTree uploads a tree from the specified path into the remote cache. | ||
| func (c *Client) UploadTree(ctx context.Context, concurrency uint64, path string) error { | ||
| uploader := newParallelUploader(ctx, c.GrpcClient, concurrency) |
There was a problem hiding this comment.
I wonder why couldn't you use UploadIfMissing directly instead of making a parallel uploaded? UploadIfMissing should already has parallel support, controlled by CASConcurrency
There was a problem hiding this comment.
I'm using this tool to upload very large trees with 10,000s files. Just iterating over all of them takes significant time, so it's more efficient to start uploading while iterating over the files in the tree.
I'll have a look if I can achieve this with the existing parallel uploading.
| execAttempts = flag.Int("exec_attempts", 10, "For check_determinism: the number of times to remotely execute the action and check for mismatches.") | ||
| operation = flag.String("operation", "", fmt.Sprintf("Specifies the operation to perform. Supported values: %v", supportedOps)) | ||
| digest = flag.String("digest", "", "Digest in <digest/size_bytes> format.") | ||
| pathPrefix = flag.String("path", "", "Path to which outputs should be downloaded to.") |
There was a problem hiding this comment.
I think this documentation should be updated?
| if _, _, err := c.GrpcClient.UploadIfMissing(ctx, ue); err != nil { | ||
| // UploadTree uploads a tree from the specified path into the remote cache. | ||
| func (c *Client) UploadTree(ctx context.Context, concurrency uint64, path string) error { | ||
| uploader := newParallelUploader(ctx, c.GrpcClient, concurrency) |
| if err := toolClient.UploadTree(context.Background(), tempDir); err != nil { | ||
| t.Fatalf("UploadTree('%v') failed: %v", tmpFile, err) | ||
| } | ||
| if cas.WriteReqs() != 4 { |
There was a problem hiding this comment.
If we are skipping the blob upload during second call to the same tempDir path, then shouldn't we have 0 write requests?
There was a problem hiding this comment.
The stats aren't reset, so they continue to be 4 from the initial upload. If the second call uploads anything we'd get > 4 here.
|
Was this superseded by remote-apis-sdks/go/pkg/tool/tool.go Line 341 in e74bc3d |
4 participants
No description provided.