CalvinBackup/OpenAirframes
1
0
Fork 0
mirror of https://github.com/PlaneQuery/OpenAirframes.git synced 2026-07-25 19:20:50 +02:00
Code Issues Packages Projects Releases Wiki Activity

deal with whole schema

Browse Source
This commit is contained in:
ggman12
2026-02-15 16:43:00 -05:00
parent 4e81dde201
commit 405855c566
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adsb/combine_chunks_to_csv.py
+3 -6
View File
@@ -101,13 +101,10 @@ def download_and_merge_base_release(compressed_df: pl.DataFrame) -> tuple[pl.Dat
if base_path and os.path.exists(str(base_path)): if base_path and os.path.exists(str(base_path)):
print(f"Loading base release from {base_path}") print(f"Loading base release from {base_path}")
base_df = pl.read_csv(base_path)
print(f"Base release has {len(base_df)} records")
# Parse time column as datetime # Read CSV with schema matching the new data
base_df = base_df.with_columns( base_df = pl.read_csv(base_path, schema=compressed_df.schema)
pl.col('time').str.to_datetime(time_unit='ms', time_zone='UTC') print(f"Base release has {len(base_df)} records")
)
# Extract earliest date from base release # Extract earliest date from base release
earliest_timestamp = base_df['time'].min() earliest_timestamp = base_df['time'].min()