We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5ae144f commit 49a6b14Copy full SHA for 49a6b14
cpueff-goweb/spark/cpueff_stepchain_goweb.py
@@ -71,7 +71,7 @@ def udf_step_extract(row):
71
_jobtype = row['meta_data']['jobtype']
72
_ts = row['meta_data']['ts']
73
if 'steps' in row and row['steps']:
74
- for step in row['steps']:
+ for step in filter(None, row['steps']):
75
if ('name' in step) and step['name'].lower().startswith('cmsrun'):
76
step_res = {'Task': _task_name, 'ts': _ts, 'fwjr_id': _fwjr_id, 'JobType': _jobtype}
77
0 commit comments