Skip to content

Commit 7a24139

Browse files
committed
Add a log about the size of the update to send.
1 parent bd401a0 commit 7a24139

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

internal/client/transaction.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,10 @@ func (cgt *Transaction) Commit() (*knowledge.Graph, error) {
9797

9898
chunkSize := cgt.chunkSize
9999

100+
fmt.Printf("Assets to be inserted=%d removed=%d, Relations to be inserted=%d removed=%d",
101+
len(bulk.GetAssetUpserts()), len(bulk.GetAssetRemovals()),
102+
len(bulk.GetRelationUpserts()), len(bulk.GetRelationRemovals()))
103+
100104
relationRemovalsChunks := utils.ChunkSlice(bulk.GetRelationRemovals(), chunkSize).([][]interface{})
101105
relationInsertionChunks := utils.ChunkSlice(bulk.GetRelationUpserts(), chunkSize).([][]interface{})
102106
assetRemovalsChunks := utils.ChunkSlice(bulk.GetAssetRemovals(), chunkSize).([][]interface{})

0 commit comments

Comments
 (0)