bugfix 609
@@ -499,10 +499,11 @@ func (t *transferQueueProcessorImpl) processCloseExecution(task *persistence.Tra
switch err.(type) {
case *workflow.EntityNotExistsError:
err = nil
- default:
- return err
}
}
+ if err != nil {
+ return err
+ }
// Record closing in visibility store
retentionSeconds := int64(0)
