diff --git a/common/reconciliation/common/util.go b/common/reconciliation/common/util.go
index 24ddf18fe05..168504c14ff 100644
--- a/common/reconciliation/common/util.go
+++ b/common/reconciliation/common/util.go
@@ -164,8 +164,8 @@ func ExecutionOpen(execution interface{}) bool {
 // getExecution returns base Execution
 func getExecution(execution interface{}) *Execution {
 	switch e := execution.(type) {
-	case *Execution:
-		return e
+	case *CurrentExecution:
+		return &e.Execution
 	case *ConcreteExecution:
 		return &e.Execution
 	default:
diff --git a/common/reconciliation/common/util_test.go b/common/reconciliation/common/util_test.go
index b5509ecc471..db383c9fb63 100644
--- a/common/reconciliation/common/util_test.go
+++ b/common/reconciliation/common/util_test.go
@@ -435,7 +435,7 @@ func (s *UtilSuite) TestDeleteExecution() {
 			execManager.On("DeleteCurrentWorkflowExecution", mock.Anything).Return(tc.deleteCurrentErr).Once()
 		}
 		pr := NewPersistenceRetryer(execManager, nil)
-		result := DeleteExecution(&Execution{}, pr)
+		result := DeleteExecution(&ConcreteExecution{}, pr)
 		s.Equal(tc.expectedFixResult, result)
 	}
 }