func()

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
}