tasks

Documentation

Index

• Variables
• func StartInvocationFinalization(ctx context.Context, id invocations.ID, updateInv bool)

Variables

var FinalizationTasks = tq.RegisterTaskClass(tq.TaskClass{
	ID:            "try-finalize-inv",
	Prototype:     &taskspb.TryFinalizeInvocation{},
	Kind:          tq.Transactional,
	Queue:         "finalizer",
	RoutingPrefix: "/internal/tasks/finalizer",
})

FinalizationTasks describes how to route finalization tasks.

The handler is implemented in internal/services/finalizer.

Functions

func StartInvocationFinalization

func StartInvocationFinalization(ctx context.Context, id invocations.ID, updateInv bool)

StartInvocationFinalization changes invocation state to FINALIZING if updateInv is set, and enqueues a TryFinalizeInvocation task.

The caller is responsible for ensuring that the invocation is active.

TODO(nodir): this package is not a great place for this function, but there is no better package at the moment. Keep it here for now, but consider a new package as the code base grows.