|
1 | 1 | # SPDX-FileCopyrightText: 2023-present deepset GmbH <info@deepset.ai> |
2 | 2 | # |
3 | 3 | # SPDX-License-Identifier: Apache-2.0 |
| 4 | + |
4 | 5 | from typing import Any, Literal, Optional, Union, overload |
5 | 6 |
|
6 | 7 | from haystack import default_from_dict, default_to_dict, logging |
@@ -1136,7 +1137,9 @@ def update_by_filter(self, filters: dict[str, Any], meta: dict[str, Any]) -> int |
1136 | 1137 | msg = "meta must be a non-empty dictionary" |
1137 | 1138 | raise ValueError(msg) |
1138 | 1139 |
|
1139 | | - update_sql = SQL("UPDATE {schema_name}.{table_name} SET meta = COALESCE(meta, '{{}}'::jsonb) || %s::jsonb").format( |
| 1140 | + update_sql = SQL( |
| 1141 | + "UPDATE {schema_name}.{table_name} SET meta = COALESCE(meta, '{{}}'::jsonb) || %s::jsonb" |
| 1142 | + ).format( |
1140 | 1143 | schema_name=Identifier(self.schema_name), |
1141 | 1144 | table_name=Identifier(self.table_name), |
1142 | 1145 | ) |
@@ -1184,7 +1187,9 @@ async def update_by_filter_async(self, filters: dict[str, Any], meta: dict[str, |
1184 | 1187 | msg = "meta must be a non-empty dictionary" |
1185 | 1188 | raise ValueError(msg) |
1186 | 1189 |
|
1187 | | - update_sql = SQL("UPDATE {schema_name}.{table_name} SET meta = COALESCE(meta, '{{}}'::jsonb) || %s::jsonb").format( |
| 1190 | + update_sql = SQL( |
| 1191 | + "UPDATE {schema_name}.{table_name} SET meta = COALESCE(meta, '{{}}'::jsonb) || %s::jsonb" |
| 1192 | + ).format( |
1188 | 1193 | schema_name=Identifier(self.schema_name), |
1189 | 1194 | table_name=Identifier(self.table_name), |
1190 | 1195 | ) |
|
0 commit comments