666
ctx context.Context,
667
request *p.DeleteCurrentWorkflowExecutionRequest,
669
>
namespaceID := primitives.MustParseUUID(request.NamespaceID)
670
>
runID := primitives.MustParseUUID(request.RunID)
671
>
_, err := m.DB.DeleteFromCurrentExecutions(ctx, sqlplugin.CurrentExecutionsFilter{
672
>
ShardID: request.ShardID,
673
>
NamespaceID: namespaceID,
674
>
WorkflowID: request.WorkflowID,
675
>
RunID: runID,
676
>
ArchetypeID: request.ArchetypeID,
677
>
})
678
>
return err
679
>
}
680
681
func (m *sqlExecutionStore) GetCurrentExecution(
682
ctx context.Context,
683
request *p.GetCurrentExecutionRequest,
684
>
) (*p.InternalGetCurrentExecutionResponse, error) {
execution.go
685
>
row, err := m.DB.SelectFromCurrentExecutions(ctx, sqlplugin.CurrentExecutionsFilter{
686
>
ShardID: request.ShardID,
687
>
NamespaceID: primitives.MustParseUUID(request.NamespaceID),
688
>
WorkflowID: request.WorkflowID,
689
>
ArchetypeID: request.ArchetypeID,
690
>
})
691
>
if err != nil {
692
if err == sql.ErrNoRows {
693
return nil, serviceerror.NewNotFound(err.Error())