File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -181,16 +181,15 @@ def adjust_ids_for_cluster(settings): #job_settings or task_settings
181181 else :
182182 mod_task_settings = []
183183 for task_settings in job_settings .get ('job_clusters' , []):
184- adjust_ids_for_cluster (task_settings )
185- if mod_task_settings :
184+ mod_task_settings . append ( adjust_ids_for_cluster (task_settings ) )
185+ if len ( mod_task_settings ) > 0 :
186186 job_settings ['job_clusters' ] = mod_task_settings
187187 mod_task_settings = []
188188
189189 # multi-task jobs may have existing_cluster_id per task
190190 for task_settings in job_settings .get ('tasks' , []):
191- adjust_ids_for_cluster (task_settings )
192- if mod_task_settings :
193- logging .info (f"mod_task_settings: { mod_task_settings } " )
191+ mod_task_settings .append (adjust_ids_for_cluster (task_settings ))
192+ if len (mod_task_settings ) > 0 :
194193 job_settings ['tasks' ] = mod_task_settings
195194
196195 logging .info ("Current Job Name: {0}" .format (job_conf ['settings' ]['name' ]))
You can’t perform that action at this time.
0 commit comments