relational.write - missing raise when a connection established (#371)

* raise in case there's a connection * update json schemas --------- Co-authored-by: github-actions <[email protected]>
datayoga-io · Aug 8, 2024 · 2dbd485 · 2dbd485
1 parent ba9dc32
commit 2dbd485
Show file tree

Hide file tree

Showing 2 changed files with 629 additions and 627 deletions.
diff --git a/core/src/datayoga_core/blocks/relational/write/block.py b/core/src/datayoga_core/blocks/relational/write/block.py
@@ -187,6 +187,8 @@ def execute(self, statement: Any, records: List[Dict[str, Any]]):
             if not connected:
                 raise ConnectionError(e) from e
 
+            raise
+
     def execute_upsert(self, records: List[Dict[str, Any]]):
         """Upserts records into the table."""
         if records: