in jobs/update_orphaning_dashboard_etl.py [0:0]
def check_code_notify_mapper(d):
ping = d
index = 0
current_version = ping.version[0]
while (index < len(ping.update_ping_count_notify) and
index < len(ping.version) and
ping.version[index] == current_version):
if (ping.update_ping_count_notify[index] > 0 and
ping.update_check_code_notify is not None):
code_index = 0
for code_value in ping.update_check_code_notify[index]:
if code_value > 0:
return code_index, ping
code_index += 1
if (ping.update_check_no_update_notify is not None and
ping.update_check_no_update_notify[index] > 0):
return 0, ping
index += 1
return -1, ping