(self, query, init_table_infos, limitation, metric, main_metric, lang_mode)
| 233 | return input_dict |
| 234 | |
| 235 | def get_features_by_llm_concurrent(self, query, init_table_infos, limitation, metric, main_metric, lang_mode): |
| 236 | results = [] |
| 237 | with ThreadPoolExecutor() as executor: |
| 238 | futures = [] |
| 239 | for _ in range(args.sc_filter_nums): |
| 240 | future = executor.submit(self.get_features_by_llm, query, init_table_infos, limitation, metric, |
| 241 | main_metric, lang_mode) |
| 242 | futures.append(future) |
| 243 | for future in futures: |
| 244 | if future.result() != "": |
| 245 | results.append(future.result()) |
| 246 | return results |
| 247 | |
| 248 | def step_get_filter_infos(self, input_dict, lang_mode, table_list, table_info_list, mode): |
| 249 | """step 2: get filter infos""" |
no outgoing calls
no test coverage detected