Skip to content

Commit

Permalink
smarter job_name assignment
Browse files Browse the repository at this point in the history
  • Loading branch information
benlindsay committed Jan 22, 2018
1 parent a4b4083 commit 1d81892
Showing 1 changed file with 8 additions and 1 deletion.
9 changes: 8 additions & 1 deletion create_jobs/create_jobs.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,14 @@ def create_jobs(file_list=None, param_table=None, base_dir='.',

# Create JOB_NAME column if not already there
if not 'JOB_NAME' in param_df.columns:
param_df['JOB_NAME'] = param_df.index
job_name_col = None
for c in param_df.columns:
if np.all(~param_df[c].duplicated()):
job_name_col = c
if job_name_col is None:
param_df['JOB_NAME'] = param_df.index
else:
param_df['JOB_NAME'] = param_df[job_name_col]

# Iterate over rows of dataframe, creating and submitting jobs
param_dict_list = param_df.to_dict(orient='records')
Expand Down

0 comments on commit 1d81892

Please sign in to comment.