in tools/mc2bq/pkg/mcutil/assetuploader.go [40:58]
func (upd *AssetUploader) Flush(ctx context.Context) error {
if len(upd.frames.FramesData) == 0 {
return nil
}
_, err := upd.mc.ReportAssetFrames(ctx, &migrationcenterpb.ReportAssetFramesRequest{
Parent: upd.source.ProjectAndLocation.Path(),
Source: upd.source.String(),
Frames: upd.frames,
})
if err != nil {
return err
}
upd.frames.FramesData = nil
return err
}