Skip to content

Commit 6f19c2d

Browse files
authored
fix: Release resource on SkipSecondAppend (#808)
In this case `writeOne` is not called on the record, so we should release it ourselves.
1 parent 6b96a47 commit 6f19c2d

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

plugins/destination/plugin_testing_write_append.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,8 @@ func (s *PluginTestSuite) destinationPluginTestWriteAppend(ctx context.Context,
5757
if err := p.writeOne(ctx, specSource, secondSyncTime, record2); err != nil {
5858
return fmt.Errorf("failed to write one second time: %w", err)
5959
}
60+
} else {
61+
record2.Release()
6062
}
6163

6264
resourcesRead, err := p.readAll(ctx, tables[0], sourceName)

0 commit comments

Comments
 (0)