Skip to content

Commit af47dc5

Browse files
committed
fix babs merge
1 parent 56ac737 commit af47dc5

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

babs/utils.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -648,10 +648,12 @@ def update_results_status(
648648
& ~updated_results_df['state'].isin(['PD', 'R'])
649649
)
650650

651-
# Drop the completion columns
652-
updated_results_df = updated_results_df.drop(
653-
columns=['job_id_completion', 'task_id_completion']
654-
)
651+
# Drop all completion columns (job_id, task_id, and any other overlapping
652+
# columns like ses_id_completion when use_sesid was False in a prior run)
653+
completion_suffix_columns = [
654+
col for col in updated_results_df.columns if col.endswith('_completion')
655+
]
656+
updated_results_df = updated_results_df.drop(columns=completion_suffix_columns)
655657

656658
return updated_results_df
657659

0 commit comments

Comments
 (0)