diff --git a/dags/queries/generate_avro/contract_data.sql b/dags/queries/generate_avro/contract_data.sql index 9fb7e60d..4c334e6b 100644 --- a/dags/queries/generate_avro/contract_data.sql +++ b/dags/queries/generate_avro/contract_data.sql @@ -7,7 +7,8 @@ options ( as ( select * - except (batch_id, batch_insert_ts, batch_run_date) + except (batch_id, batch_insert_ts, batch_run_date, asset_code) + , replace(asset_code, '\u0000', '') as asset_code from {project_id}.{dataset_id}.contract_data where true