73
)
74
76
>
if params.NamespaceID.IsEmpty() {
77
return errors.NewInvalidArgument("namespace ID is required", nil)
78
}
80
return errors.NewInvalidArgument("namespace is required", nil)
81
}
83
params.FirstRunStartTime = workflow.Now(ctx).UTC()
84
}
86
>
return nil
87
}
88
89
>
func DeleteExecutionsWorkflow(ctx workflow.Context, params DeleteExecutionsParams) (DeleteExecutionsResult, error) {
workflow.go
90
>
logger := log.With(
91
>
workflow.GetLogger(ctx),
92
>
tag.WorkflowType(WorkflowName),
93
>
tag.WorkflowNamespace(params.Namespace.String()),
94
>
tag.WorkflowNamespaceID(params.NamespaceID.String()))
95
>
96
>
logger.Info("Workflow started.")
97
>
result := DeleteExecutionsResult{
98
>
SuccessCount: params.PreviousSuccessCount,
99
>
ErrorCount: params.PreviousErrorCount,
100
>
}
101
>
102
>
if err := validateParams(ctx, ¶ms); err != nil {
103
return result, err
104
}
106
>
107
>
if err := workflow.SetQueryHandler(ctx, StatsQuery, func() (DeleteExecutionsStats, error) {
108
now := workflow.Now(ctx).UTC()
109
des := DeleteExecutionsStats{