in tools/mc2bq/pkg/mcutil/assetuploader.go [60:70]
func (upd *AssetUploader) Upload(ctx context.Context, frame *migrationcenterpb.AssetFrame) error {
upd.frames.FramesData = append(upd.frames.FramesData, frame)
if len(upd.frames.FramesData) == maxAssetsPerFrame {
err := upd.Flush(ctx)
if err != nil {
return err
}
}
return nil
}