Update lambda_function.py

ddps-lab · Aug 9, 2023 · c805a93 · c805a93
1 parent 17009e7
commit c805a93
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/collector/spot-dataset/gcp/lambda/lambda_function.py b/collector/spot-dataset/gcp/lambda/lambda_function.py
@@ -10,7 +10,7 @@
 from const_config import GcpCollector, Storage
 from load_pricelist import get_price, preprocessing_price, drop_negative
 from get_metadata import get_aggregated_list, parsing_data_from_aggragated_list
-from s3_management import save_raw, update_latest, upload_timestream, load_metadata
+from s3_management import save_raw, update_latest, upload_timestream, load_metadata, update_query_selector
 from compare_data import compare
 from utility import slack_msg_sender
 
@@ -93,6 +93,8 @@ def gcp_collect(timestamp):
 
     changed_df, removed_df = compare(df_previous, df_current, workload_cols, feature_cols)
 
+    update_query_selector(changed_df)
+
     # wirte timestream
     upload_timestream(changed_df, timestamp)
     upload_timestream(removed_df, timestamp)