task

Documentation

Overview

Package task handle task scheduling for culprit verification.

Index

• Variables
• func RegisterTaskClass(...)
• func ScheduleTestFailureTask(ctx context.Context, analysisID int64) error

Variables

var CompileFailureTasks = tq.RegisterTaskClass(tq.TaskClass{
	ID:        "culprit-verification",
	Prototype: (*tpb.CulpritVerificationTask)(nil),
	Queue:     "culprit-verification",
	Kind:      tq.NonTransactional,
})

CompileFailureTasks describes how to route compile failure culprit verification tasks.

var TestFailureTasks = tq.RegisterTaskClass(tq.TaskClass{
	ID:        "test-failure-culprit-verification",
	Prototype: (*tpb.TestFailureCulpritVerificationTask)(nil),
	Queue:     "test-failure-culprit-verification",
	Kind:      tq.NonTransactional,
})

TestFailureTasks describes how to route test failure culprit verification tasks.

Functions

func RegisterTaskClass

func RegisterTaskClass(compileHandler, testHandler func(ctx context.Context, payload proto.Message) error)

RegisterTaskClass registers the task class for tq dispatcher

func ScheduleTestFailureTask

func ScheduleTestFailureTask(ctx context.Context, analysisID int64) error

ScheduleTestFailureTask schedules a task for test failure culprit verification.