Cannot pickle connection object

Question

I am using following code to connect to the SQL Server and return the connection in order to be able to use in other function. However, I am getting an error of can't pickle pyodbc.Connection objects

The code is:

def connect_to_the_DB(**kwargs):
    #Connection to SQL Server
    conn = pyodbc.connect(driver='{ODBC Driver 17 for SQL Server}',
                          server='test.co.uk',
                          database='testdb',
                          uid='crm',
                          pwd='test123')
    print("Connection established")
    logging.info("Connection established")
    return conn

Any tips, how I can solve it?

I am using Apache Airflow. So, I am assigning functions to the tasks.@CDJB — Nazrin Guliyeva, Jan 06 '20 at 14:59

score 2 · Answer 1 · answered Jan 06 '20 at 15:05

Some objects are not picklable (see Pickling unpicklable objects). I've had the same issue with Redis connections which seem similar to this, though I'm not sure.

The general advice is to extract the data you need and only pickle that, rather than the connection itself.

Cannot pickle connection object

1 Answers1