APPS.FA_MASS_DPR_RSV_ADJ_PKG dependencies on FA_WORKER_JOBS

Line 826: FROM FA_WORKER_JOBS

822: l_failed_cnt,
823: l_wip_cnt,
824: l_completed_cnt,
825: l_total_cnt
826: FROM FA_WORKER_JOBS
827: WHERE request_Id = p_parent_request_id;
828:
829: if (g_log_level_rec.statement_level) then
830: fa_debug_pkg.add(l_calling_fn,'Job status - Unassigned: '||l_unassigned_cnt||

Line 858: UPDATE FA_WORKER_JOBS

854: fa_debug_pkg.add(l_calling_fn,'All jobs completed, no more job. Terminating','');
855: end if;
856: raise done_exc;
857: ELSIF (l_unassigned_cnt > 0) THEN
858: UPDATE FA_WORKER_JOBS
859: SET status = 'IN PROCESS',
860: worker_num = p_request_number
861: WHERE status = 'UNASSIGNED'
862: AND request_Id = p_parent_request_id

Line 885: g_phase := 'Getting ID range from FA_WORKER_JOBS table';

881: -- -----------------------------------
882: IF (l_count > 0) THEN
883: DECLARE
884: BEGIN
885: g_phase := 'Getting ID range from FA_WORKER_JOBS table';
886:
887: if (g_log_level_rec.statement_level) then
888: fa_debug_pkg.add(l_calling_fn,g_phase,'');
889: end if;

Line 895: FROM FA_WORKER_JOBS

891: SELECT start_range,
892: end_range
893: INTO l_start_range,
894: l_end_range
895: FROM FA_WORKER_JOBS
896: WHERE worker_num = p_request_number
897: AND request_Id = p_parent_request_id
898: AND status = 'IN PROCESS';
899:

Line 922: g_phase:='Updating job status in FA_WORKER_JOBS table';

918: -- process
919: -- After completing the work, set the job status
920: -- to complete
921: -----------------------------------------------------
922: g_phase:='Updating job status in FA_WORKER_JOBS table';
923: if (g_log_level_rec.statement_level) then
924: fa_debug_pkg.add(l_calling_fn,g_phase,'');
925: end if;
926:

Line 927: UPDATE FA_WORKER_JOBS

923: if (g_log_level_rec.statement_level) then
924: fa_debug_pkg.add(l_calling_fn,g_phase,'');
925: end if;
926:
927: UPDATE FA_WORKER_JOBS
928: SET status = 'COMPLETED'
929: WHERE request_id = p_parent_request_id
930: AND worker_num = p_request_number
931: AND status = 'IN PROCESS';

Line 945: UPDATE FA_WORKER_JOBS

941: FA_SRVR_MSG.ADD_SQL_ERROR(
942: CALLING_FN => l_calling_fn,
943: p_log_level_rec => g_log_level_rec);
944:
945: UPDATE FA_WORKER_JOBS
946: SET status = 'FAILED'
947: WHERE request_id = p_parent_request_id
948: AND worker_num = p_request_number
949: AND status = 'IN PROCESS';

Line 1077: g_phase := 'Loop to insert into FA_WORKER_JOBS: '

1073:
1074: WHILE (l_start_number <= l_max_number) LOOP
1075:
1076: l_end_number:= l_start_number + l_batch_size;
1077: g_phase := 'Loop to insert into FA_WORKER_JOBS: '
1078: || l_start_number || ', ' || l_end_number;
1079:
1080: l_count := l_count + 1;
1081: INSERT INTO FA_WORKER_JOBS (start_range, end_range, status, request_id)

Line 1081: INSERT INTO FA_WORKER_JOBS (start_range, end_range, status, request_id)

1077: g_phase := 'Loop to insert into FA_WORKER_JOBS: '
1078: || l_start_number || ', ' || l_end_number;
1079:
1080: l_count := l_count + 1;
1081: INSERT INTO FA_WORKER_JOBS (start_range, end_range, status, request_id)
1082: VALUES (l_start_number, least(l_end_number, l_max_number),'UNASSIGNED');
1083:
1084:
1085: l_start_number := least(l_end_number, l_max_number) + 1;

Line 1091: INSERT INTO FA_WORKER_JOBS

1087: END LOOP; -- (l_start_number <= l_max_number)
1088:
1089: */
1090:
1091: INSERT INTO FA_WORKER_JOBS
1092: (START_RANGE, END_RANGE, WORKER_NUM, STATUS,REQUEST_ID)
1093: SELECT MIN(ASSET_ID), MAX(ASSET_ID), 0,
1094: 'UNASSIGNED', p_parent_request_id
1095: FROM ( SELECT /*+ parallel(BK) */

Line 1104: fa_debug_pkg.add(l_calling_fn,'Inserted ' || SQL%ROWCOUNT || ' jobs into FA_WORKER_JOBS table','');

1100: AND BK.TRANSACTION_HEADER_ID_OUT IS NULL )
1101: GROUP BY UNIT_ID;
1102:
1103: if (g_log_level_rec.statement_level) then
1104: fa_debug_pkg.add(l_calling_fn,'Inserted ' || SQL%ROWCOUNT || ' jobs into FA_WORKER_JOBS table','');
1105: end if;
1106:
1107: fnd_concurrent.af_commit;
1108: