junos
/
rapids
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Clean utils.py

pull/103/head
JulioV 2020-09-01 12:02:31 -04:00
parent d674010e08
commit 681a77f23c
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/features/utils/utils.py
View File

@ -24,14 +24,11 @@ def fetch_provider_features(provider, provider_key, config_key, sensor_data_file
for day_segment in day_segments_labels["label"]: for day_segment in day_segments_labels["label"]:
print("{} Processing {} {} {}".format(rapids_log_tag, config_key, provider_key, day_segment)) print("{} Processing {} {} {}".format(rapids_log_tag, config_key, provider_key, day_segment))
print("---")
features = feature_function(sensor_data, day_segment, provider, filter_data_by_segment=filter_data_by_segment) features = feature_function(sensor_data, day_segment, provider, filter_data_by_segment=filter_data_by_segment)
print("2")
sensor_features = sensor_features.merge(features, how="outer") sensor_features = sensor_features.merge(features, how="outer")
else: else:
for feature in provider["FEATURES"]: for feature in provider["FEATURES"]:
sensor_features[feature] = None sensor_features[feature] = None
print("3")
segment_colums = pd.DataFrame() segment_colums = pd.DataFrame()
split_segemnt_columns = sensor_features["local_segment"].str.split(pat="#", expand=True) split_segemnt_columns = sensor_features["local_segment"].str.split(pat="#", expand=True)
new_segment_columns = split_segemnt_columns if split_segemnt_columns.shape[1] == 5 else pd.DataFrame(columns=["local_segment_label", "local_start_date", "local_start_time", "local_end_date", "local_end_time"]) new_segment_columns = split_segemnt_columns if split_segemnt_columns.shape[1] == 5 else pd.DataFrame(columns=["local_segment_label", "local_start_date", "local_start_time", "local_end_date", "local_end_time"])