144: END IF;
145: --
146: -- Clean up AD update information in case number of workers changed
147: -- Note: this procedure implicitly commits
148: AD_PARALLEL_UPDATES_PKG.delete_update_information(
149: ad_parallel_updates_pkg.ID_RANGE,
150: l_gl_schema,
151: g_table_name,
152: g_script_name);
145: --
146: -- Clean up AD update information in case number of workers changed
147: -- Note: this procedure implicitly commits
148: AD_PARALLEL_UPDATES_PKG.delete_update_information(
149: ad_parallel_updates_pkg.ID_RANGE,
150: l_gl_schema,
151: g_table_name,
152: g_script_name);
153: --
257: g_api || '.' || fn_name,
258: 'x_argument4 = ' || x_argument4);
259: END IF;
260: --
261: ad_parallel_updates_pkg.initialize_id_range(
262: ad_parallel_updates_pkg.ID_RANGE,
263: x_argument4,
264: g_table_name,
265: g_script_name,
258: 'x_argument4 = ' || x_argument4);
259: END IF;
260: --
261: ad_parallel_updates_pkg.initialize_id_range(
262: ad_parallel_updates_pkg.ID_RANGE,
263: x_argument4,
264: g_table_name,
265: g_script_name,
266: g_id_column,
267: x_worker_id,
268: x_num_workers,
269: x_batch_size, 0);
270: --
271: ad_parallel_updates_pkg.get_id_range(
272: l_start_id,
273: l_end_id,
274: l_any_rows_to_process,
275: x_batch_size,
283: l_rows_processed := prepare_recon_update(l_start_id,l_end_id);
284: --
285: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_rows_processed : ' || l_rows_processed);
286: --
287: ad_parallel_updates_pkg.processed_id_range(
288: l_rows_processed,
289: l_end_id);
290: --
291: fnd_concurrent.af_commit;
289: l_end_id);
290: --
291: fnd_concurrent.af_commit;
292: --
293: ad_parallel_updates_pkg.get_id_range(
294: l_start_id,
295: l_end_id,
296: l_any_rows_to_process,
297: x_batch_size,