259:
260: --Fetch the index of the last list_line_id processed successfully.
261: l_index := l_list_line_id_tbl.LAST;
262:
263: --Update the qp_upg_lines_distribution table's record for the current worker and
264: --line_type with the last list_line_id successfully processed.
265: UPDATE qp_upg_lines_distribution
266: SET last_proc_line = l_list_line_id_tbl(l_index)
267: WHERE worker = p_worker
261: l_index := l_list_line_id_tbl.LAST;
262:
263: --Update the qp_upg_lines_distribution table's record for the current worker and
264: --line_type with the last list_line_id successfully processed.
265: UPDATE qp_upg_lines_distribution
266: SET last_proc_line = l_list_line_id_tbl(l_index)
267: WHERE worker = p_worker
268: AND line_type = p_line_type;
269:
368: l_total_workers number;
369:
370: Begin
371:
372: delete from qp_upg_lines_distribution
373: where line_type = v_type;
374:
375: commit;
376: