in jobs/update_orphaning_dashboard_etl.py [0:0]
def state_failure_code_stage_mapper(d):
ping = d
current_version = ping.version[0]
for index, version in enumerate(ping.version):
if ping.update_status_error_code_partial_stage is not None:
code_index = 0
for code_value in ping.update_status_error_code_partial_stage[index]:
if code_value > 0:
if version == current_version:
return code_index, ping
return -1, ping
code_index += 1
if ping.update_status_error_code_complete_stage is not None:
code_index = 0
for code_value in ping.update_status_error_code_complete_stage[index]:
if code_value > 0:
if version == current_version:
return code_index, ping
return -1, ping
code_index += 1
if ping.update_status_error_code_unknown_stage is not None:
code_index = 0
for code_value in ping.update_status_error_code_unknown_stage[index]:
if code_value > 0:
if version == current_version:
return code_index, ping
return -1, ping
code_index += 1
return -2, ping