Skip to content

Commit a1f542e

Browse files
@LouisFunmula index -> update 🤦
Thank you Louis for this!
1 parent d1d2e23 commit a1f542e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pg_es_fdw/fdw.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ def update(self, document_id, new_values):
119119
_, document = self.columns.serialize(new_values)
120120

121121
try:
122-
response = self.client.index(
122+
response = self.client.update(
123123
id=document_id,
124124
body=document,
125125
refresh=self.options.refresh,
@@ -130,7 +130,7 @@ def update(self, document_id, new_values):
130130
return {self.options.rowid_column: response["_id"]}
131131
except Exception as exception:
132132
log2pg(
133-
"INDEX for {path}/{document_id} and document {document} failed: {exception}".format(
133+
"UPDATE for {path}/{document_id} and document {document} failed: {exception}".format(
134134
path=self.options.path,
135135
document_id=document_id,
136136
document=new_values,

0 commit comments

Comments
 (0)