Update classify.py
Browse files- classify.py +2 -2
classify.py
CHANGED
|
@@ -10,7 +10,7 @@ from utils import setup_logging, load_system_prompt, load_queries, load_checkpoi
|
|
| 10 |
|
| 11 |
def run_inference(cfg, df_input, ckpt_df, all_rows, total, future_to_idx, start_time, logger):
|
| 12 |
completed = 0
|
| 13 |
-
print("before: \n", df_input.columns)
|
| 14 |
with tqdm.tqdm(total=total, desc="Classifying") as pbar:
|
| 15 |
for future in as_completed(future_to_idx):
|
| 16 |
try:
|
|
@@ -43,7 +43,7 @@ def run_inference(cfg, df_input, ckpt_df, all_rows, total, future_to_idx, start_
|
|
| 43 |
else:
|
| 44 |
combined = batch_df
|
| 45 |
save_checkpoint(combined, cfg)
|
| 46 |
-
print("after: \n", all_rows)
|
| 47 |
|
| 48 |
# --- Final output ---
|
| 49 |
final_df = pd.concat([df_input, pd.DataFrame(all_rows).drop(columns=[cfg.data[cfg.level].query_column])], axis=1)
|
|
|
|
| 10 |
|
| 11 |
def run_inference(cfg, df_input, ckpt_df, all_rows, total, future_to_idx, start_time, logger):
|
| 12 |
completed = 0
|
| 13 |
+
# print("before: \n", df_input.columns)
|
| 14 |
with tqdm.tqdm(total=total, desc="Classifying") as pbar:
|
| 15 |
for future in as_completed(future_to_idx):
|
| 16 |
try:
|
|
|
|
| 43 |
else:
|
| 44 |
combined = batch_df
|
| 45 |
save_checkpoint(combined, cfg)
|
| 46 |
+
# print("after: \n", all_rows)
|
| 47 |
|
| 48 |
# --- Final output ---
|
| 49 |
final_df = pd.concat([df_input, pd.DataFrame(all_rows).drop(columns=[cfg.data[cfg.level].query_column])], axis=1)
|