Delete running workflow executions (#2819)

temporalio · May 12, 2022 · cf4153c · cf4153c
1 parent a089ae5
commit cf4153c
Show file tree

Hide file tree

Showing 35 changed files with 1,039 additions and 490 deletions.
diff --git a/api/persistence/v1/executions.pb.go b/api/persistence/v1/executions.pb.go
diff --git a/common/persistence/serialization/task_serializer.go b/common/persistence/serialization/task_serializer.go
@@ -505,6 +505,7 @@ func (s *TaskSerializer) transferCloseTaskToProto(
 		Version:                 closeTask.Version,
 		TaskId:                  closeTask.TaskID,
 		VisibilityTime:          timestamp.TimePtr(closeTask.VisibilityTimestamp),
+		DeleteAfterClose:        closeTask.DeleteAfterClose,
 	}
 }
 
@@ -520,6 +521,7 @@ func (s *TaskSerializer) transferCloseTaskFromProto(
 		VisibilityTimestamp: *closeTask.VisibilityTime,
 		TaskID:              closeTask.TaskId,
 		Version:             closeTask.Version,
+		DeleteAfterClose:    closeTask.DeleteAfterClose,
 	}
 }
 

diff --git a/host/onebox.go b/host/onebox.go
@@ -765,6 +765,10 @@ func (c *temporalImpl) overrideHistoryDynamicConfig(client *dynamicClient) {
 	if c.historyConfig.HistoryCountLimitError != 0 {
 		client.OverrideValue(dynamicconfig.HistoryCountLimitError, c.historyConfig.HistoryCountLimitError)
 	}
+
+	// For DeleteWorkflowExecution tests
+	client.OverrideValue(dynamicconfig.TransferProcessorUpdateAckInterval, 1*time.Second)
+	client.OverrideValue(dynamicconfig.VisibilityProcessorUpdateAckInterval, 1*time.Second)
 }
 
 func (c *temporalImpl) RefreshNamespaceCache() {