tasks/service/history/interfaces/workflow_task_info.go

package interfaces

import (
	"time"

	enumspb "go.temporal.io/api/enums/v1"
	taskqueuepb "go.temporal.io/api/taskqueue/v1"
	enumsspb "github.com/hanzoai/tasks/api/enums/v1"
	"github.com/hanzoai/tasks/service/history/tasks"
)

// TODO: This should be part of persistence layer
type WorkflowTaskInfo struct {
	Version             int64
	ScheduledEventID    int64
	StartedEventID      int64
	RequestID           string
	WorkflowTaskTimeout time.Duration
	// This is only needed to communicate task queue used after AddWorkflowTaskScheduledEvent.
	TaskQueue *taskqueuepb.TaskQueue

	// Attempt is the number of attempts for this workflow task.
	Attempt int32
	// AttemptsSinceLastSuccess is the number of attempts since the last successful workflow task.
	// This is used by the `TemporalReportedProblems` search attribute to check latest WFT failure count,
	// this will only differ from attempts above when the previous workflow tasks failed and there was a
	// buffered event (like a signal or activity finishing) applied to the workflow which causes the
	// new workflow task to have an attempt of 1 again.
	AttemptsSinceLastSuccess int32

	// Scheduled and Started timestamps are useful for transient workflow task: when transient workflow task finally completes,
	// use these Timestamp to create scheduled/started events.
	// Also used for recording latency metrics
	ScheduledTime time.Time
	StartedTime   time.Time
	// OriginalScheduledTime is to record the first scheduled workflow task during workflow task heartbeat.
	// Client may to heartbeat workflow task by RespondWorkflowTaskComplete with ForceCreateNewWorkflowTask == true
	// In this case, OriginalScheduledTime won't change. Then when time.Now().UTC()-OriginalScheduledTime exceeds
	// some threshold, server can interrupt the heartbeat by enforcing to time out the workflow task.
	OriginalScheduledTime time.Time

	// Indicate type of the current workflow task (normal, transient, or speculative).
	Type enumsspb.WorkflowTaskType

	// These two fields are sent to workers in the WorkflowTaskStarted event. We need to save a
	// copy in mutable state to know the last values we sent (which might have been in a
	// transient event), otherwise a dynamic config change of the suggestion threshold could
	// cause the WorkflowTaskStarted event that the worker used to not match the event we saved
	// in history.
	SuggestContinueAsNew        bool
	SuggestContinueAsNewReasons []enumspb.SuggestContinueAsNewReason
	HistorySizeBytes            int64

	TargetWorkerDeploymentVersionChanged bool
	// BuildIdRedirectCounter tracks the started build ID redirect counter for transient/speculative WFT. This
	// info is to make sure the right redirect counter is used in the WFT started event created later
	// for a transient/speculative WFT.
	// Deprecated.
	BuildIdRedirectCounter int64
	// BuildId tracks the started build ID for transient/speculative WFT. This info is used for two purposes:
	// - verify WFT completes by the same Build ID that started in the latest attempt
	// - when persisting transient/speculative WFT, the right Build ID is used in the WFT started event
	// Deprecated.
	BuildId string

	// Persisted timeout tasks for this workflow task. These are set when the timeout tasks are generated
	// and used to delete them when the workflow task completes.
	ScheduleToStartTimeoutTask *tasks.WorkflowTaskTimeoutTask
	StartToCloseTimeoutTask    *tasks.WorkflowTaskTimeoutTask

	// Incrementing Stamp will invalidate the existing transfer/matching workflow task.
	// Incrementing Stamp will ensure that the standby clusters reschedule the transfer tasks properly.
	// Stamp is NOT scoped within a single wft, and it should never be decremented in the lifetime of the whole execution.
	Stamp int32
}

type WorkflowTaskCompletionLimits struct {
	MaxResetPoints              int
	MaxSearchAttributeValueSize int
}