Skip to content

Commit 1ca9bb0

Browse files
committed
feat: update disk retrieval to use base path for attached disks
1 parent 2022c51 commit 1ca9bb0

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

thunder-service/job/gcp_data_retrieve_job.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ package job
1717
import (
1818
"context"
1919
"fmt"
20+
"path"
2021
"sync"
2122
"time"
2223

@@ -207,7 +208,7 @@ func (job *GcpDataRetrieveJob) Run() {
207208
for _, attachedDisk := range instance.Disks {
208209
diskWg.Add(1)
209210

210-
disk, err := job.GetDisk(ctx, project.ProjectId, attachedDisk.GetDeviceName(), instance.Zone())
211+
disk, err := job.GetDisk(ctx, project.ProjectId, path.Base(attachedDisk.GetSource()), instance.Zone())
211212
if err != nil {
212213
gcperr := model.GcpError{
213214
SeqValue: seqValue,

0 commit comments

Comments
 (0)