baselineupdater

Documentation

Overview

Package baselineupdater marks test variants from an invocation as submitted by adding the test variants to the set of tests for its baseline identifier.

Index

• Variables
• func InitServer(srv *server.Server)
• func Schedule(ctx context.Context, invID string)

Variables

var BaselineUpdaterTasks = tq.RegisterTaskClass(tq.TaskClass{
	ID:            "update-baseline",
	Prototype:     &taskspb.MarkInvocationSubmitted{},
	Kind:          tq.Transactional,
	Queue:         "baselineupdater",
	RoutingPrefix: "/internal/tasks/baselineupdater",
})

BaselineUpdaterTasks describes how to route mark submitted tasks.

var TransactionLimit = 8000

TransactionLimit is set to 8000 because Cloud Spanner limits 40k mutations per transaction. We have 5 columns to write to per row, and 40,000/5 = 8000.

Functions

func InitServer

func InitServer(srv *server.Server)

InitServer initializes a baselineupdator server.

func Schedule

func Schedule(ctx context.Context, invID string)