diff --git a/tap_mssql/sync_strategies/common.py b/tap_mssql/sync_strategies/common.py
index 82801a7f..c6613742 100755
--- a/tap_mssql/sync_strategies/common.py
+++ b/tap_mssql/sync_strategies/common.py
@@ -126,7 +126,7 @@ def prepare_columns_sql(catalog_entry, c):
                     """
         elif sql_data_type == 'datetimeoffset':
             return f"""case when {column_name} is not null then
-                      CONVERT(VARCHAR,dt_offset_col,127)
+                      CONVERT(VARCHAR,{column_name},127)
                     else null end
                     """