Commit 68cfa708 authored by 赵威's avatar 赵威

add exception check

parent 16657fe8
...@@ -18,8 +18,7 @@ def click_feature_engineering(click_df, conversion_df): ...@@ -18,8 +18,7 @@ def click_feature_engineering(click_df, conversion_df):
nullseries = cc_df.isnull().sum() nullseries = cc_df.isnull().sum()
nulls = nullseries[nullseries > 0] nulls = nullseries[nullseries > 0]
if nulls.any(): if nulls.any():
print("!!!!!!!!!!!!!!!!!!!!!!\n")
print(nulls) print(nulls)
print("!!!!!!!!!!!!!!!!!!!!!!\n") raise Exception("click_feature_engineering nulls")
return cc_df return cc_df
...@@ -122,5 +122,5 @@ def device_feature_engineering(device_df, content_type): ...@@ -122,5 +122,5 @@ def device_feature_engineering(device_df, content_type):
nulls = nullseries[nullseries > 0] nulls = nullseries[nullseries > 0]
if nulls.any(): if nulls.any():
print(nulls) print(nulls)
print("!!!!!!!!!!!!!!!!!!!!!!\n") raise Exception("device_feature_engineering nulls")
return df[columns] return df[columns]
...@@ -423,9 +423,8 @@ def diary_feature_engineering(df): ...@@ -423,9 +423,8 @@ def diary_feature_engineering(df):
nullseries = diary_df.isnull().sum() nullseries = diary_df.isnull().sum()
nulls = nullseries[nullseries > 0] nulls = nullseries[nullseries > 0]
if nulls.any(): if nulls.any():
print("!!!!!!!!!!!!!!!!!!!!!!\n")
print(nulls) print(nulls)
print("!!!!!!!!!!!!!!!!!!!!!!\n") raise Exception("diary_feature_engineering nulls")
return diary_df return diary_df
...@@ -499,9 +498,8 @@ def join_features(device_df, diary_df, cc_df): ...@@ -499,9 +498,8 @@ def join_features(device_df, diary_df, cc_df):
nullseries = df.isnull().sum() nullseries = df.isnull().sum()
nulls = nullseries[nullseries > 0] nulls = nullseries[nullseries > 0]
if nulls.any(): if nulls.any():
print("!!!!!!!!!!!!!!!!!!!!!!\n")
print(nulls) print(nulls)
print("!!!!!!!!!!!!!!!!!!!!!!\n") raise Exception("diary join_features nulls")
drop_columns = [ drop_columns = [
"cl_id", "first_demands_x", "first_demands_y", "first_demands", "second_demands_x", "second_demands_y", "second_demands", "cl_id", "first_demands_x", "first_demands_y", "first_demands", "second_demands_x", "second_demands_y", "second_demands",
......
...@@ -409,9 +409,8 @@ def tractate_feature_engineering(tractate_df): ...@@ -409,9 +409,8 @@ def tractate_feature_engineering(tractate_df):
nullseries = df.isnull().sum() nullseries = df.isnull().sum()
nulls = nullseries[nullseries > 0] nulls = nullseries[nullseries > 0]
if nulls.any(): if nulls.any():
print("!!!!!!!!!!!!!!!!!!!!!!\n")
print(nulls) print(nulls)
print("!!!!!!!!!!!!!!!!!!!!!!\n") raise Exception("tractate_feature_engineering nulls")
return df return df
...@@ -485,9 +484,8 @@ def join_features(device_df, tractate_df, cc_df): ...@@ -485,9 +484,8 @@ def join_features(device_df, tractate_df, cc_df):
nullseries = df.isnull().sum() nullseries = df.isnull().sum()
nulls = nullseries[nullseries > 0] nulls = nullseries[nullseries > 0]
if nulls.any(): if nulls.any():
print("!!!!!!!!!!!!!!!!!!!!!!\n")
print(nulls) print(nulls)
print("!!!!!!!!!!!!!!!!!!!!!!\n") raise Exception("tractate join_features nulls")
print(df.shape) print(df.shape)
drop_columns = [ drop_columns = [
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment