diff --git a/pkg/cron_workflow.go b/pkg/cron_workflow.go
index 8f5826c..c64bc49 100644
--- a/pkg/cron_workflow.go
+++ b/pkg/cron_workflow.go
@@ -528,6 +528,9 @@ func (c *Client) TerminateCronWorkflow(namespace, uid string) (err error) {
 	if err != nil {
 		return err
 	}
+	if err := tx.Commit(); err != nil {
+		return err
+	}
 
 	err = c.ArchiveCronWorkflowDB(namespace, uid)
 	if err != nil {
@@ -729,6 +732,10 @@ func (c *Client) ArchiveCronWorkflowDB(namespace, uid string) error {
 	if err != nil {
 		return err
 	}
+	if err := tx.Commit(); err != nil {
+		return err
+	}
+
 	return nil
 }
 
diff --git a/pkg/workflow_execution.go b/pkg/workflow_execution.go
index 0e10590..0416570 100644
--- a/pkg/workflow_execution.go
+++ b/pkg/workflow_execution.go
@@ -1502,5 +1502,8 @@ func (c *Client) ArchiveWorkflowExecutionDB(namespace, uid string) error {
 	if err != nil {
 		return err
 	}
+	if err := tx.Commit(); err != nil {
+		return err
+	}
 	return nil
 }