diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index b41d37df..c0de985b 100644 --- a/RELEASE_NOTES.md +++ b/RELEASE_NOTES.md @@ -24,6 +24,7 @@ - Replaced entity with getter (#652) - Resolved TODO in Dockerfile (#680) - Resolved TODO at src/reporter/tests/test_timescale_types.py (#667) +- Resolved TODO at src/translator/sql_translator.py (#697) ### Bug fixes diff --git a/src/translators/sql_translator.py b/src/translators/sql_translator.py index fe66fc03..18df28fa 100644 --- a/src/translators/sql_translator.py +++ b/src/translators/sql_translator.py @@ -362,15 +362,12 @@ def _insert_entity_rows(self, table_name: str, col_names: List[str], stmt = f"insert into {table_name} ({col_list}) values ({placeholders})" try: start_time = datetime.now() + res_list = [] for batch in to_insert_batches(rows): res = self.cursor.executemany(stmt, batch) - # new version of crate does not bomb anymore when - # something goes wrong in multi entries - # simply it returns -2 for each row that have an issue - # TODO: improve error handling. - # using batches, we don't need to fail the whole set - # but only failing batches. + res_list.append(res) + for res in res_list: if isinstance(res, list): for i in range(len(res)): if res[i]['rowcount'] < 0: