Проблема с unixODBC decoding with 'utf-16le'

File "/usr/lib/python3.8/encodings/utf_16_le.py", line 15, in decode
    def decode(input, errors='strict'):
  File "/usr/local/lib/python3.8/dist-packages/airflow/models/taskinstance.py", line 1543, in signal_handler
    raise AirflowException("Task received SIGTERM signal")
airflow.exceptions.AirflowException: Task received SIGTERM signal
 
The above exception was the direct cause of the following exception:
 
airflow.exceptions.AirflowException: decoding with 'utf-16le' codec failed (AirflowException: Task received SIGTERM signal)

def decode_sketchy_utf16(raw_bytes):
    s = raw_bytes.decode("utf-16le", "ignore")
    try:
        n = s.index('\u0000')
        s = s[:n]  # respect null terminator
    except ValueError:
        pass
    return s
 
# ...
 
prev_converter = cnxn.get_output_converter(pyodbc.SQL_WVARCHAR)
cnxn.add_output_converter(pyodbc.SQL_WVARCHAR, decode_sketchy_utf16)
col_info = crsr.columns("Clients").fetchall()
cnxn.add_output_converter(pyodbc.SQL_WVARCHAR, prev_converter)  # restore previous behaviour

--- connecting to DWH
def dwh_conn():
    mySQL = '192.168.240.1'
    myDB = 'DWH'
    login = 'sa'
    PWD = '...'
    Encrypt = 'No'
    Certificate = 'Yes'
 
    params = urllib.parse.quote_plus("DRIVER={ODBC Driver 18 for SQL Server};"
                                     "SERVER=" + mySQL + ";"
                                                         "SERVER=" + mySQL + ";"
                                                                             "Port=1433" + ";"
                                                                                           "DATABASE=" + myDB + ";"
                                                                                                                "UID=" + login + ";"
                                                                                                                                 "PWD=" + PWD + ";"
                                                                                                                                                "Encrypt=" + Encrypt + ";"
                                                                                                                                                                       "TrustServerCertificate=" + Certificate + ";")
    engine = sa.create_engine('mssql+pyodbc:///?odbc_connect={}?charset=utf8mb4'.format(params), fast_executemany=False)
    return engine
 
--- connecting to database to get data
def gladiator_conn():
    mySQL = '...'
    myDB = '...'
    login = '...'
    PWD = '...'
    Encrypt = 'No'
    Certificate = 'Yes'
    params = urllib.parse.quote_plus("DRIVER={ODBC Driver 18 for SQL Server};"
                                     "SERVER=" + mySQL + ";"
                                                         "Port=1433" + ";"
                                                                       "DATABASE=" + myDB + ";"
                                                                                            "UID=" + login + ";"
                                                                                                             "PWD=" + PWD + ";"
                                                                                                                            "Encrypt=" + Encrypt + ";"
                                                                                                                                                   "TrustServerCertificate=" + Certificate + ";")
    engine = sa.create_engine('mssql+pyodbc:///?odbc_connect={}?charset=utf8mb4'.format(params), fast_executemany=False)
    return engine
 
---example of getting data and inserting into DWH 
def update_from_gladiator_ost(market_id):    
    query = "DELETE from [stage].[dbo].[rests_by_docs_temp] where market_id = %d" % market_id
    execute_query_dwh(query)
    engine = dwh_conn()
    connection = engine.raw_connection()
    abc = connection.cursor()
    # abc.execute("DELETE from [stage].[dbo].[sell_movement_temp]; DELETE from [stage].[dbo].[rests_by_docs_temp]")
    df_op = pd.read_sql(
            "SET NOCOUNT ON exec [dbo].[mp_report_finance_agent_enhanced_basis_transport_royalty_NC_ost_by_docs4] @pmarket_id = %d, @pstart_date = '%s', @pend_date = '%s', @pselect = '1'" % (
            market_id, z, w), gladiator_conn())
    df_op = df_op.fillna(value=0)
    for row_count in range(0, df_op.shape[0]):
        chunk = df_op.iloc[row_count:row_count + 1, :].values.tolist()
        tuple_of_tuples = tuple(tuple(x) for x in chunk)
        abc.executemany(
                "insert into stage.dbo.rests_by_docs_temp" + " ([date_start],[market_id],[good_id],[agent_id],[doc_id],[tstart_qty],[tstart_amt],[IMP],[doc_name]) values   (?,?,?,?,?,?,?,?,?)",
                tuple_of_tuples)
        abc.commit()
    connection.close()