[GitHub] [airflow] kaxil commented on issue #9606: Turn off pickling of XCom by default in 2.0

[GitBox <gi...@apache.org>]

kaxil commented on issue #9606:
URL: https://github.com/apache/airflow/issues/9606#issuecomment-845192785


   > Hello, I am using airflow 2.0.2, I am trying the following code, and it gives me this error. I have calling the function get_activated_sources from python operator. I am trying to pass the values to the next sql fille.
   > 
   > Not sure if it's normal in airflow 2.0.2.
   > 
   > def get_activated_sources():
   > 
   > ```
   >     
   >     PostgreConn = PostgresHook(postgres_conn_id='redshift', schema='reports')
   >     db_conn = PostgreConn.get_conn()
   >     cursor = db_conn.cursor()
   >     cursor.execute("SELECT id_pais, nombre, codigo, paisplataforma, pais_longitud, pais_latitud, nombre_eng FROM mstr_new.dw_lu_pais;")
   >    
   >     return cursor
   > ```
   > 
   > **Error**
   > `[2021-05-20 07:04:27,350] {xcom.py:237} ERROR - Could not serialize the XCom value into JSON. If you are using pickles instead of JSON for XCom, then you need to enable pickle support for XCom in your airflow config.`
   
   @maryampashmi  "cursos" will not contain the return values after running the SQL query. You could use `PostgresHook. get_records()` function
   
   https://github.com/apache/airflow/blob/733bec9a04ab718a0f6289d93f4e2e4ea3e03d54/airflow/hooks/dbapi.py#L119-L135


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org