940
ctx context.Context,
941
request *p.DeleteCurrentWorkflowExecutionRequest,
943
>
query := d.Session.Query(templateDeleteWorkflowExecutionCurrentRowQuery,
944
>
request.ShardID,
945
>
rowTypeExecution,
946
>
request.NamespaceID,
947
>
request.WorkflowID,
948
>
d.getCurrentRecordRunID(request.ArchetypeID),
949
>
defaultVisibilityTimestamp,
950
>
rowTypeExecutionTaskID,
951
>
request.RunID,
952
>
).WithContext(ctx)
953
>
954
>
err := query.Exec()
955
>
return gocql.ConvertError("DeleteWorkflowCurrentRow", err)
956
>
}
957
958
func (d *MutableStateStore) GetCurrentExecution(