sort by time in end

This commit is contained in:
ggman12
2026-02-15 20:33:06 -05:00
parent 9964ce576b
commit 7a62faecef
+3
View File
@@ -131,6 +131,9 @@ def download_and_merge_base_release(compressed_df: pl.DataFrame) -> tuple[pl.Dat
combined = pl.concat([base_df, compressed_df]) combined = pl.concat([base_df, compressed_df])
print(f"After concat: {len(combined)} records") print(f"After concat: {len(combined)} records")
# Sort by time for consistent output
combined = combined.sort('time')
return combined, earliest_date return combined, earliest_date
def cleanup_chunks(output_id: str, chunks_dir: str): def cleanup_chunks(output_id: str, chunks_dir: str):