Skip to content
This repository was archived by the owner on Mar 13, 2025. It is now read-only.

Commit 39c2541

Browse files
Pass transactionId during update of top resource
1 parent 6ba12fe commit 39c2541

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/services/ProcessorService.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,11 +98,12 @@ async function processUpdate (message, transactionId) {
9898
const client = await helper.getESClient()
9999
const { index, type } = topResources[resource]
100100
const id = message.payload.id
101-
const source = await client.get({ index, type, id, transaction: true })
101+
const source = await client.get({ index, type, id, transactionId })
102102
await client.update({
103103
index,
104104
type,
105105
id,
106+
transactionId,
106107
body: {
107108
doc: _.assign(source._source, _.omit(message.payload, 'resource'))
108109
},

0 commit comments

Comments
 (0)