APPS.FA_MASSCP_PKG dependencies on FA_PARALLEL_WORKERS

Line 86: from fa_parallel_workers fpw,

82: fpw.transaction_type_code,
83: fpw.corp_transaction_header_id,
84: fpw.tax_transaction_header_id,
85: af.asset_id same_asset_id_fail
86: from fa_parallel_workers fpw,
87: fa_asset_failures_gt af
88: where fpw.request_id = p_parent_request_id
89: and fpw.process_status = 'UNASSIGNED'
90: and fpw.worker_number = p_request_number

Line 373: update fa_parallel_workers fpw

369: end loop; -- array loop
370:
371: -- now flags the rows process status accordingly
372: forall i in 1..l_rowid.count
373: update fa_parallel_workers fpw
374: set process_status = l_process_status(i)
375: where rowid = l_rowid(i);
376:
377: if (g_log_level_rec.statement_level) then

Line 378: fa_debug_pkg.add(l_calling_fn, 'rows updated in fa_parallel_workers for status', l_rowid.count,

374: set process_status = l_process_status(i)
375: where rowid = l_rowid(i);
376:
377: if (g_log_level_rec.statement_level) then
378: fa_debug_pkg.add(l_calling_fn, 'rows updated in fa_parallel_workers for status', l_rowid.count,
379: p_log_level_rec => g_log_level_rec);
380: end if;
381:
382:

Line 2365: from fa_parallel_workers fpw_p,

2361: cursor c_parent_assets (p_parent_request_id number) is
2362: select distinct
2363: fpw_p.asset_id,
2364: fpw_p.worker_number
2365: from fa_parallel_workers fpw_p,
2366: fa_parallel_workers fpw_c
2367: where fpw_p.request_id = p_parent_request_id
2368: and fpw_p.transaction_type_code = 'ADDITION'
2369: and (fpw_p.parent_asset_id is null or

Line 2366: fa_parallel_workers fpw_c

2362: select distinct
2363: fpw_p.asset_id,
2364: fpw_p.worker_number
2365: from fa_parallel_workers fpw_p,
2366: fa_parallel_workers fpw_c
2367: where fpw_p.request_id = p_parent_request_id
2368: and fpw_p.transaction_type_code = 'ADDITION'
2369: and (fpw_p.parent_asset_id is null or
2370: not exists

Line 2372: from fa_parallel_workers fpw_p1

2368: and fpw_p.transaction_type_code = 'ADDITION'
2369: and (fpw_p.parent_asset_id is null or
2370: not exists
2371: (select 1
2372: from fa_parallel_workers fpw_p1
2373: where fpw_p1.request_id = p_parent_request_id
2374: and fpw_p1.asset_id = fpw_p.parent_asset_id
2375: and fpw_p1.transaction_type_code = 'ADDITION'))
2376: and fpw_c.request_id = fpw_p.request_id

Line 2400: from fa_parallel_workers fpw1

2396: cursor c_child_assets (p_parent_asset_id number,
2397: p_parent_request_id number) is
2398: select fpw1.asset_id,
2399: level
2400: from fa_parallel_workers fpw1
2401: start with fpw1.asset_id = p_parent_asset_id
2402: and fpw1.request_id = p_parent_request_id
2403: and fpw1.transaction_type_code = 'ADDITION'
2404: connect by prior fpw1.asset_id = fpw1.parent_asset_id

Line 2552: insert into fa_parallel_workers

2548: -- bug fix 5925965 (Initial Mass Copy copies capitalized assets to wrong fiscal year and period in TAX book)
2549: l_date_effective := nvl(l_corp_period_rec.period_close_date, sysdate);
2550: -- End bug fix 5925965
2551:
2552: insert into fa_parallel_workers
2553: (request_id ,
2554: asset_id ,
2555: asset_number ,
2556: asset_type ,

Line 2650: insert into fa_parallel_workers

2646: fa_debug_pkg.add(l_calling_fn, 'opening c_per_trx_child cursor at', sysdate,
2647: p_log_level_rec => g_log_level_rec);
2648: end if;
2649:
2650: insert into fa_parallel_workers
2651: (request_id ,
2652: asset_id ,
2653: asset_number ,
2654: asset_type ,

Line 2758: fa_debug_pkg.add(l_calling_fn, 'rows inserted into fa_parallel_workers', sql%rowcount,

2754:
2755: end if;
2756:
2757: if (g_log_level_rec.statement_level) then
2758: fa_debug_pkg.add(l_calling_fn, 'rows inserted into fa_parallel_workers', sql%rowcount,
2759: p_log_level_rec => g_log_level_rec);
2760: end if;
2761:
2762: FND_CONCURRENT.AF_COMMIT;

Line 2822: update fa_parallel_workers

2818:
2819: -- note update by asset id instead of rowid is intentional
2820: -- we need all lines for the asset to go to the same worker
2821: forall i in 1..l_child_asset_id.count
2822: update fa_parallel_workers
2823: set worker_number = l_child_worker_number(i),
2824: process_order = l_child_process_order(i) + l_group_increment
2825: where request_id = p_parent_request_id
2826: and asset_id = l_child_asset_id(i);