We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents b7b6eb6 + 12b837d commit 70c36fbCopy full SHA for 70c36fb
airflow/etl_pipelines/scrapers/StationObservationPipeline/StationObservationPipeline.py
@@ -184,7 +184,7 @@ def download_data(self):
184
# Since from here on out the columns will be the stripped ones, if they have changed
185
# our schema_overrides from above may not have applied
186
# Perform CAST-ing as necessary
187
- if(key in self.expected_dtype):
+ if(key in self.expected_dtype and self.name != "ASP"):
188
data_df = data_df.cast(self.expected_dtype[key], strict=False)
189
190
# __downloaded_data contains the path to the downloaded data if go_through_all_stations is False
0 commit comments