mik-laj commented on issue #13354: URL: https://github.com/apache/airflow/issues/13354#issuecomment-751933484
> I get the same error no matter what query I run. Execution of the query works fine, but it appears to fail on the final return; from the operator code: return response.primary_results[0] The operator should only return data that is JSON serializable. In the case of Google integration, it looks like this: https://github.com/apache/airflow/blob/8c00ec89b97aa6e725379d08c8ff29a01be47e73/airflow/providers/google/cloud/sensors/pubsub.py#L202 or https://github.com/apache/airflow/blob/8c42cf1b00c90f0d7f11b8a3a455381de8e003c5/airflow/providers/google/cloud/hooks/vision.py#L225 > The operator also doesn't have an xcom_push param, so I couldn't find a way to turn off this functionality. In Airflow 2.0, we have global parameter in BaseOperator. https://github.com/apache/airflow/blob/a4aa32b875c4d24264f195910c08214c22607943/airflow/models/baseoperator.py#L278-L280 Are you willing to submit a PR? I am happy to help with the review. ---------------------------------------------------------------- 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: [email protected]
