func()

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
}