922
ctx context.Context,
923
request *p.DeleteWorkflowExecutionRequest,
925
>
query := d.Session.Query(templateDeleteWorkflowExecutionMutableStateQuery,
926
>
request.ShardID,
927
>
rowTypeExecution,
928
>
request.NamespaceID,
929
>
request.WorkflowID,
930
>
request.RunID,
931
>
defaultVisibilityTimestamp,
932
>
rowTypeExecutionTaskID,
933
>
).WithContext(ctx)
934
>
935
>
err := query.Exec()
936
>
return gocql.ConvertError("DeleteWorkflowExecution", err)
937
>
}
938
939
func (d *MutableStateStore) DeleteCurrentWorkflowExecution(