mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Fred TzengandDan Davison
110e24062d
Added standalone activity completion and failure handling. Refactored existing timeout failure handling. Refactored existing check for retry method. Needed to support standalone activities full operation. - [X] built - [X] run locally and tested manually - [X] covered by existing tests - [X] added new unit test(s) - [X] added new functional test(s) --------- Co-authored-by: Dan Davison <[email protected]>
60 lines
1.4 KiB
Go
60 lines
1.4 KiB
Go
package tasktoken
|
|
|
|
import (
|
|
clockspb "go.temporal.io/server/api/clock/v1"
|
|
tokenspb "go.temporal.io/server/api/token/v1"
|
|
"google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
func NewWorkflowTaskToken(
|
|
namespaceID string,
|
|
workflowID string,
|
|
runID string,
|
|
scheduledEventID int64,
|
|
startedEventId int64,
|
|
startedTime *timestamppb.Timestamp,
|
|
attempt int32,
|
|
clock *clockspb.VectorClock,
|
|
version int64,
|
|
) *tokenspb.Task {
|
|
return &tokenspb.Task{
|
|
NamespaceId: namespaceID,
|
|
WorkflowId: workflowID,
|
|
RunId: runID,
|
|
ScheduledEventId: scheduledEventID,
|
|
StartedEventId: startedEventId,
|
|
StartedTime: startedTime,
|
|
Attempt: attempt,
|
|
Clock: clock,
|
|
Version: version,
|
|
}
|
|
}
|
|
|
|
func NewActivityTaskToken(
|
|
namespaceID string,
|
|
workflowID string,
|
|
runID string,
|
|
scheduledEventID int64,
|
|
activityId string,
|
|
activityType string,
|
|
attempt int32,
|
|
clock *clockspb.VectorClock,
|
|
version int64,
|
|
startVersion int64,
|
|
componentRef []byte,
|
|
) *tokenspb.Task {
|
|
return &tokenspb.Task{
|
|
NamespaceId: namespaceID,
|
|
WorkflowId: workflowID,
|
|
RunId: runID,
|
|
ScheduledEventId: scheduledEventID,
|
|
ActivityType: activityType,
|
|
Attempt: attempt,
|
|
ActivityId: activityId,
|
|
Clock: clock,
|
|
Version: version,
|
|
StartVersion: startVersion,
|
|
ComponentRef: componentRef,
|
|
}
|
|
}
|