Update app.py

app.py

@@ -115,9 +115,11 @@ async def mergeStreams(request: Request):
         # transform stream_data to dataframe (create a backup copy of this dataframe)
         df = get_dataframe(stream_data, return_original_df=False)
         df_B = df.copy()
-
-        excludeCol = ["id","totalChildrenCount", "applicationId", "layer"]
-        aggregated_df_b, log_dict = aggregate_data_optimized(df_A.copy(), df_B.copy(), 'uuid', 'graph_geometry_id',excludeCol)
+        
+        excludeCol = config["EXCLUDE_COLS"]
+        uuidCol = config["UUID_COL"]
+        refCol = config["REFERENCE_COL"]
+        aggregated_df_b, log_dict = aggregate_data_optimized(df_A.copy(), df_B.copy(), uuidCol, refCol,excludeCol)
 
 
         # additional cleanups, remove geometry and fill  na