diff --git a/core/src/datayoga_core/blocks/relational/write/block.py b/core/src/datayoga_core/blocks/relational/write/block.py
index 0524e1f8..0e1720e3 100644
--- a/core/src/datayoga_core/blocks/relational/write/block.py
+++ b/core/src/datayoga_core/blocks/relational/write/block.py
@@ -186,7 +186,7 @@ def execute(self, statement: Any, records: List[Dict[str, Any]]):
                             2055,  # CR_SERVER_LOST_EXTENDED
                         )
 
-                        if e.orig and e.orig.args[0] in mysql_conn_errors:
+                        if e.orig.args[0] in mysql_conn_errors:
                             connected = False
 
                     raise