APPS.FA_MASS_DPR_RSV_ADJ_PKG dependencies on FA_WORKER_JOBS

Line 838: FROM FA_WORKER_JOBS

834: l_failed_cnt,
835: l_wip_cnt,
836: l_completed_cnt,
837: l_total_cnt
838: FROM FA_WORKER_JOBS
839: WHERE request_Id = p_parent_request_id;
840:
841: if (g_log_level_rec.statement_level) then
842: fa_debug_pkg.add(l_calling_fn,'Job status - Unassigned: '||l_unassigned_cnt||

Line 870: UPDATE FA_WORKER_JOBS

866: fa_debug_pkg.add(l_calling_fn,'All jobs completed, no more job. Terminating','');
867: end if;
868: raise done_exc;
869: ELSIF (l_unassigned_cnt > 0) THEN
870: UPDATE FA_WORKER_JOBS
871: SET status = 'IN PROCESS',
872: worker_num = p_request_number
873: WHERE status = 'UNASSIGNED'
874: AND request_Id = p_parent_request_id

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

893: -- -----------------------------------
894: IF (l_count > 0) THEN
895: DECLARE
896: BEGIN
897: g_phase := 'Getting ID range from FA_WORKER_JOBS table';
898:
899: if (g_log_level_rec.statement_level) then
900: fa_debug_pkg.add(l_calling_fn,g_phase,'');
901: end if;

Line 907: FROM FA_WORKER_JOBS

903: SELECT start_range,
904: end_range
905: INTO l_start_range,
906: l_end_range
907: FROM FA_WORKER_JOBS
908: WHERE worker_num = p_request_number
909: AND request_Id = p_parent_request_id
910: AND status = 'IN PROCESS';
911:

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

930: -- process
931: -- After completing the work, set the job status
932: -- to complete
933: -----------------------------------------------------
934: g_phase:='Updating job status in FA_WORKER_JOBS table';
935: if (g_log_level_rec.statement_level) then
936: fa_debug_pkg.add(l_calling_fn,g_phase,'');
937: end if;
938:

Line 939: UPDATE FA_WORKER_JOBS

935: if (g_log_level_rec.statement_level) then
936: fa_debug_pkg.add(l_calling_fn,g_phase,'');
937: end if;
938:
939: UPDATE FA_WORKER_JOBS
940: SET status = 'COMPLETED'
941: WHERE request_id = p_parent_request_id
942: AND worker_num = p_request_number
943: AND status = 'IN PROCESS';

Line 957: UPDATE FA_WORKER_JOBS

953: FA_SRVR_MSG.ADD_SQL_ERROR(
954: CALLING_FN => l_calling_fn,
955: p_log_level_rec => g_log_level_rec);
956:
957: UPDATE FA_WORKER_JOBS
958: SET status = 'FAILED'
959: WHERE request_id = p_parent_request_id
960: AND worker_num = p_request_number
961: AND status = 'IN PROCESS';

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

1085:
1086: WHILE (l_start_number <= l_max_number) LOOP
1087:
1088: l_end_number:= l_start_number + l_batch_size;
1089: g_phase := 'Loop to insert into FA_WORKER_JOBS: '
1090: || l_start_number || ', ' || l_end_number;
1091:
1092: l_count := l_count + 1;
1093: INSERT INTO FA_WORKER_JOBS (start_range, end_range, status, request_id)

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

1089: g_phase := 'Loop to insert into FA_WORKER_JOBS: '
1090: || l_start_number || ', ' || l_end_number;
1091:
1092: l_count := l_count + 1;
1093: INSERT INTO FA_WORKER_JOBS (start_range, end_range, status, request_id)
1094: VALUES (l_start_number, least(l_end_number, l_max_number),'UNASSIGNED');
1095:
1096:
1097: l_start_number := least(l_end_number, l_max_number) + 1;

Line 1103: INSERT INTO FA_WORKER_JOBS

1099: END LOOP; -- (l_start_number <= l_max_number)
1100:
1101: */
1102:
1103: INSERT INTO FA_WORKER_JOBS
1104: (START_RANGE, END_RANGE, WORKER_NUM, STATUS,REQUEST_ID)
1105: SELECT MIN(ASSET_ID), MAX(ASSET_ID), 0,
1106: 'UNASSIGNED', p_parent_request_id
1107: FROM ( SELECT /*+ parallel(BK) */

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

1112: AND BK.TRANSACTION_HEADER_ID_OUT IS NULL )
1113: GROUP BY UNIT_ID;
1114:
1115: if (g_log_level_rec.statement_level) then
1116: fa_debug_pkg.add(l_calling_fn,'Inserted ' || SQL%ROWCOUNT || ' jobs into FA_WORKER_JOBS table','');
1117: end if;
1118:
1119: fnd_concurrent.af_commit;
1120: