We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9b39507 commit 231e677Copy full SHA for 231e677
rt_segment_speeds/scripts/average_segment_speeds.py
@@ -98,21 +98,18 @@ def annual_time_of_day_averages(
98
**orig_dtypes,
99
},
100
align_dataframes = False
101
- )
102
-
103
- avg_speeds = avg_speeds.compute()
104
+ ).compute()
+
105
106
publish_utils.if_exists_then_delete(
107
f"{SEGMENT_GCS}{EXPORT_FILE}"
108
)
109
110
avg_speeds.to_parquet(
111
- f"{SEGMENT_GCS}{EXPORT_FILE}",
112
- partition_on = "time_of_day"
+ f"{SEGMENT_GCS}{EXPORT_FILE}.parquet",
113
114
'''
115
- speeds_gdf = delayed(segment_calcs.merge_in_segment_geometry)(
+ speeds_gdf = segment_calcs.merge_in_segment_geometry(
116
avg_speeds,
117
analysis_date_list,
118
segment_type,
0 commit comments