From 562de895d17546017b47c2916d366fe6b7b09f06 Mon Sep 17 00:00:00 2001 From: nikodemas <47255905+nikodemas@users.noreply.github.com> Date: Thu, 18 Jan 2024 15:05:18 +0100 Subject: [PATCH] Update cpueff_stepchain_goweb.py --- cpueff-goweb/spark/cpueff_stepchain_goweb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cpueff-goweb/spark/cpueff_stepchain_goweb.py b/cpueff-goweb/spark/cpueff_stepchain_goweb.py index d4a6ab4f..b8e4cf39 100644 --- a/cpueff-goweb/spark/cpueff_stepchain_goweb.py +++ b/cpueff-goweb/spark/cpueff_stepchain_goweb.py @@ -70,7 +70,7 @@ def udf_step_extract(row): _fwjr_id = row['meta_data']['fwjr_id'] _jobtype = row['meta_data']['jobtype'] _ts = row['meta_data']['ts'] - if 'steps' in row: + if 'steps' in row and row['steps']: for step in row['steps']: if ('name' in step) and step['name'].lower().startswith('cmsrun'): step_res = {'Task': _task_name, 'ts': _ts, 'fwjr_id': _fwjr_id, 'JobType': _jobtype}