Miguel Caballero Pinto
05/23/2023, 12:08 AMBigQueryPandasIOManager
. When the job is going to write to the table it fails because one of the columns in the dataframe is being translated to integer instead of string. This seems to happen because the column in the dataframe is None and dagster by default may infer that the type is an integer. This is the error I get:
google.api_core.exceptions.BadRequest: 400 Provided Schema does not match Table innate-empire-283902:enrichment.person_batch_enrichment_output. Field error_code has changed type from STRING to INTEGER
Is there a way to workaround this? How can I tell dagster that the output type of the column is a string?owen
05/23/2023, 12:17 AMerror_code
column within pandas, i.e.
my_df = ...
my_df.error_code = my_df.error_code.astype(str)
this should ensure that this column is interpreted as a stringMiguel Caballero Pinto
05/23/2023, 12:18 AMdtype
argument of the dataframe constructor?owen
05/23/2023, 12:26 AM