Skip to content

Commit d95406a

Browse files
Skip BufferedEvents persistence when empty (#707)
1 parent b7c75e2 commit d95406a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

common/persistence/executionStore.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -406,7 +406,7 @@ func (m *executionManagerImpl) SerializeWorkflowMutation(
406406
}
407407

408408
var serializedNewBufferedEvents *serialization.DataBlob
409-
if input.NewBufferedEvents != nil {
409+
if len(input.NewBufferedEvents) > 0 {
410410
serializedNewBufferedEvents, err = m.serializer.SerializeBatchEvents(input.NewBufferedEvents, encoding)
411411
if err != nil {
412412
return nil, err

0 commit comments

Comments
 (0)