DBA Data[Home] [Help]

APPS.HZ_PARTY_STAGE dependencies on FND_CONCURRENT

Line 2395: from Fnd_Concurrent_Requests R

2391: -- assume that all concurrent workers completed normally, unless found otherwise
2392: l_workers_completed := TRUE;
2393:
2394: Select request_id BULK COLLECT into l_sub_requests
2395: from Fnd_Concurrent_Requests R
2396: Where Parent_Request_Id = FND_GLOBAL.conc_request_id
2397: and (phase_code<>'C' or status_code<>'C');
2398:
2399: IF l_sub_requests.count>0 THEN

Line 3042: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req1),

3038: outandlog('Waiting for workers to complete');
3039:
3040: BEGIN
3041: IF l_req1 <> 1 THEN
3042: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req1),
3043: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3044: IF dphase <> 'COMPLETE' THEN
3045: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3046: FND_MESSAGE.SET_TOKEN('ID' ,l_req1);

Line 3057: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req2),

3053: RAISE FND_API.G_EXC_ERROR;
3054: END IF;
3055: END IF;
3056: IF l_req2 <> 1 THEN
3057: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req2),
3058: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3059: IF dphase <> 'COMPLETE' THEN
3060: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3061: FND_MESSAGE.SET_TOKEN('ID' ,l_req2);

Line 3072: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req3),

3068: RAISE FND_API.G_EXC_ERROR;
3069: END IF;
3070: END IF;
3071: IF l_req3 <> 1 THEN
3072: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req3),
3073: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3074: IF dphase <> 'COMPLETE' THEN
3075: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3076: FND_MESSAGE.SET_TOKEN('ID' ,l_req3);

Line 3087: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req4),

3083: RAISE FND_API.G_EXC_ERROR;
3084: END IF;
3085: END IF;
3086: IF l_req4 <> 1 THEN
3087: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req4),
3088: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3089: IF dphase <> 'COMPLETE' THEN
3090: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3091: FND_MESSAGE.SET_TOKEN('ID' ,l_req3);

Line 3102: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req5),

3098: RAISE FND_API.G_EXC_ERROR;
3099: END IF;
3100: END IF;
3101: IF l_req5 <> 1 THEN
3102: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req5),
3103: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3104: IF dphase <> 'COMPLETE' THEN
3105: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3106: FND_MESSAGE.SET_TOKEN('ID' ,l_req4);

Line 3117: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req6),

3113: RAISE FND_API.G_EXC_ERROR;
3114: END IF;
3115: END IF;
3116: IF l_req6 <> 1 THEN
3117: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req6),
3118: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3119: IF dphase <> 'COMPLETE' THEN
3120: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3121: FND_MESSAGE.SET_TOKEN('ID' ,l_req5);

Line 3132: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req7),

3128: RAISE FND_API.G_EXC_ERROR;
3129: END IF;
3130: END IF;
3131: IF l_req7 <> 1 THEN
3132: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req7),
3133: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3134: IF dphase <> 'COMPLETE' THEN
3135: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3136: FND_MESSAGE.SET_TOKEN('ID' ,l_req6);

Line 3147: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req8),

3143: RAISE FND_API.G_EXC_ERROR;
3144: END IF;
3145: END IF;
3146: IF l_req8 <> 1 THEN
3147: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req8),
3148: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3149: IF dphase <> 'COMPLETE' THEN
3150: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3151: FND_MESSAGE.SET_TOKEN('ID' ,l_req8);

Line 3162: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req9),

3158: RAISE FND_API.G_EXC_ERROR;
3159: END IF;
3160: END IF;
3161: IF l_req9 <> 1 THEN
3162: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req9),
3163: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3164: IF dphase <> 'COMPLETE' THEN
3165: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3166: FND_MESSAGE.SET_TOKEN('ID' ,l_req9);

Line 3177: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req10),

3173: RAISE FND_API.G_EXC_ERROR;
3174: END IF;
3175: END IF;
3176: IF l_req10 <> 1 THEN
3177: l_bool := FND_CONCURRENT.wait_for_request(TO_NUMBER(l_req10),
3178: 30, 144000, uphase, ustatus, dphase, dstatus, message);
3179: IF dphase <> 'COMPLETE' THEN
3180: FND_MESSAGE.SET_NAME('AR', 'HZ_STAGE_WORKER_ERROR');
3181: FND_MESSAGE.SET_TOKEN('ID' ,l_req10);

Line 3304: FND_Concurrent.af_commit;

3300: where rnum = 1000;
3301: update hz_staged_parties set d_ps = 'SYNC', d_ct = 'SYNC', d_cpt = 'SYNC', concat_col = concat_col
3302: where party_id between l_min_id and tmp;
3303: AD_CTX_DDL.sync_index(l_index_owner|| '.hz_stage_parties_t1');
3304: FND_Concurrent.af_commit;
3305: l_min_id:=tmp+1;
3306: END LOOP;
3307: EXCEPTION
3308: WHEN NO_DATA_FOUND THEN

Line 3313: FND_Concurrent.af_commit;

3309: update hz_staged_parties set concat_col = concat_col,
3310: d_ps = 'SYNC', d_ct = 'SYNC', d_cpt = 'SYNC'
3311: where party_id between l_min_id and l_max_id ;
3312: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_parties_t1');
3313: FND_Concurrent.af_commit;
3314: WHEN OTHERS THEN
3315: FND_FILE.put_line(FND_FILE.log, 'Error during DENORM PARTY Index Synchronization SQLEERM=' ||SQLERRM);
3316: retcode := 2;
3317: errbuf := SQLERRM;

Line 3344: FND_Concurrent.af_commit;

3340: where party_id between l_min_id and tmp;
3341: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_parties_t1 index');
3342: AD_CTX_DDL.sync_index(l_index_owner|| '.hz_stage_parties_t1');
3343: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_parties_t1 index successful');
3344: FND_Concurrent.af_commit;
3345: l_min_id:=tmp+1;
3346: END LOOP;
3347: EXCEPTION
3348: WHEN NO_DATA_FOUND THEN

Line 3354: FND_Concurrent.af_commit;

3350: where party_id between l_min_id and l_max_id ;
3351: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_parties_t1 index');
3352: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_parties_t1');
3353: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_parties_t1 index successful');
3354: FND_Concurrent.af_commit;
3355: WHEN OTHERS THEN
3356: FND_FILE.put_line(FND_FILE.log, 'Error during PARTY Index Synchronization SQLEERM=' ||SQLERRM);
3357: retcode := 2;
3358: errbuf := SQLERRM;

Line 3391: FND_Concurrent.af_commit;

3387: where party_id between l_min_id and tmp;
3388: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_party_sites_t1 index');
3389: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_party_sites_t1');
3390: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_party_sites_t1 index successful');
3391: FND_Concurrent.af_commit;
3392: l_min_id:=tmp+1;
3393: END LOOP;
3394: EXCEPTION
3395: WHEN NO_DATA_FOUND THEN

Line 3401: FND_Concurrent.af_commit;

3397: where party_site_id between l_min_id and l_max_id ;
3398: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_party_sites_t1 index');
3399: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_party_sites_t1');
3400: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_party_sites_t1 index successful');
3401: FND_Concurrent.af_commit;
3402: WHEN OTHERS THEN
3403: FND_FILE.put_line(FND_FILE.log, 'Error during PARTY SITES Index Synchronization SQLEERM=' ||SQLERRM);
3404: retcode := 2;
3405: errbuf := SQLERRM;

Line 3439: FND_Concurrent.af_commit;

3435: where org_contact_id between l_min_id and tmp;
3436: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_contact_t1 index');
3437: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_contact_t1');
3438: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_contact_t1 index successful');
3439: FND_Concurrent.af_commit;
3440: l_min_id:=tmp+1;
3441: END LOOP;
3442: EXCEPTION
3443: WHEN NO_DATA_FOUND THEN

Line 3449: FND_Concurrent.af_commit;

3445: where org_contact_id between l_min_id and l_max_id ;
3446: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_contact_t1 index');
3447: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_contact_t1');
3448: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_contact_t1 index successful');
3449: FND_Concurrent.af_commit;
3450: WHEN OTHERS THEN
3451: FND_FILE.put_line(FND_FILE.log, 'Error during CONTACTS Index Synchronization SQLEERM=' ||SQLERRM);
3452: retcode := 2;
3453: errbuf := SQLERRM;

Line 3487: FND_Concurrent.af_commit;

3483: where contact_point_id between l_min_id and tmp;
3484: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_cpt_t1 index');
3485: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_cpt_t1');
3486: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_cpt_t1 index successful');
3487: FND_Concurrent.af_commit;
3488: l_min_id:=tmp+1;
3489: END LOOP;
3490: EXCEPTION
3491: WHEN NO_DATA_FOUND THEN

Line 3497: FND_Concurrent.af_commit;

3493: where contact_point_id between l_min_id and l_max_id ;
3494: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_cpt_t1 index');
3495: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_cpt_t1');
3496: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_cpt_t1 index successful');
3497: FND_Concurrent.af_commit;
3498: WHEN OTHERS THEN
3499: FND_FILE.put_line(FND_FILE.log, 'Error during CONTACT POINTS Index Synchronization SQLEERM=' ||SQLERRM);
3500: retcode := 2;
3501: errbuf := SQLERRM;

Line 5360: l(' FND_CONCURRENT.AF_Commit;');

5356: l(' END; ');
5357: l(' END IF; ');
5358: l('');
5359: l(' IF l_last_fetch THEN');
5360: l(' FND_CONCURRENT.AF_Commit;');
5361: l(' EXIT;');
5362: l(' END IF;');
5363: l('');
5364: l(' FND_CONCURRENT.AF_Commit;');

Line 5364: l(' FND_CONCURRENT.AF_Commit;');

5360: l(' FND_CONCURRENT.AF_Commit;');
5361: l(' EXIT;');
5362: l(' END IF;');
5363: l('');
5364: l(' FND_CONCURRENT.AF_Commit;');
5365: l('');
5366: l(' END LOOP;');
5367: l(' log (''End Synchronizing Parties''); ');
5368: l(' END;');

Line 5657: l(' call_status := FND_CONCURRENT.GET_REQUEST_STATUS(');

5653: l('');
5654: l(' BEGIN');
5655: l(' req_id := FND_GLOBAL.CONC_REQUEST_ID;');
5656: l(' LOOP');
5657: l(' call_status := FND_CONCURRENT.GET_REQUEST_STATUS(');
5658: l(' req_id, null,null,rphase,rstatus,dphase,dstatus,message);');
5659: l(' IF dstatus = ''TERMINATING'' THEN');
5660: l(' FND_FILE.put_line(FND_FILE.log,''Aborted by User'');');
5661: l(' RAISE USER_TERMINATE;');

Line 5781: l(' FND_CONCURRENT.AF_Commit;');

5777: l(' ROLLBACK to party_batch;');
5778: l(' RAISE;');
5779: l(' END;');
5780: l(' IF l_last_fetch THEN');
5781: l(' FND_CONCURRENT.AF_Commit;');
5782: l(' EXIT;');
5783: l(' END IF;');
5784: l(' FND_CONCURRENT.AF_Commit;');
5785: l(' END LOOP;');

Line 5784: l(' FND_CONCURRENT.AF_Commit;');

5780: l(' IF l_last_fetch THEN');
5781: l(' FND_CONCURRENT.AF_Commit;');
5782: l(' EXIT;');
5783: l(' END IF;');
5784: l(' FND_CONCURRENT.AF_Commit;');
5785: l(' END LOOP;');
5786: l(' END;');
5787:
5788: l('');

Line 6770: l(' FND_CONCURRENT.AF_Commit;');

6766: l(' log (''Eror Message is - ''|| sqlerrm); ');
6767: l(' END; ');
6768: l(' END IF; ');
6769: l('');
6770: l(' FND_CONCURRENT.AF_Commit;');
6771: l(' EXIT;');
6772: l(' END IF;');
6773: l('');
6774: l(' FND_CONCURRENT.AF_Commit;');

Line 6774: l(' FND_CONCURRENT.AF_Commit;');

6770: l(' FND_CONCURRENT.AF_Commit;');
6771: l(' EXIT;');
6772: l(' END IF;');
6773: l('');
6774: l(' FND_CONCURRENT.AF_Commit;');
6775: l('');
6776: l(' END LOOP;');
6777: l(' log (''End Synchronizing Party Sites''); ');
6778: l(' END;');

Line 8077: l(' FND_CONCURRENT.AF_Commit;');

8073: l(' log (''Eror Message is - ''|| sqlerrm); ');
8074: l(' END; ');
8075: l(' END IF; ');
8076: l('');
8077: l(' FND_CONCURRENT.AF_Commit;');
8078: l(' EXIT;');
8079: l(' END IF;');
8080: l('');
8081: l(' FND_CONCURRENT.AF_Commit;');

Line 8081: l(' FND_CONCURRENT.AF_Commit;');

8077: l(' FND_CONCURRENT.AF_Commit;');
8078: l(' EXIT;');
8079: l(' END IF;');
8080: l('');
8081: l(' FND_CONCURRENT.AF_Commit;');
8082: l('');
8083: l(' END LOOP;');
8084: l(' log (''End Synchronizing Contacts''); ');
8085: l(' END;');

Line 9354: l(' FND_CONCURRENT.AF_Commit;');

9350: l(' log (''Eror Message is - ''|| sqlerrm); ');
9351: l(' END; ');
9352: l(' END IF; ');
9353: l('');
9354: l(' FND_CONCURRENT.AF_Commit;');
9355: l(' EXIT;');
9356: l(' END IF;');
9357: l('');
9358: l(' FND_CONCURRENT.AF_Commit;');

Line 9358: l(' FND_CONCURRENT.AF_Commit;');

9354: l(' FND_CONCURRENT.AF_Commit;');
9355: l(' EXIT;');
9356: l(' END IF;');
9357: l('');
9358: l(' FND_CONCURRENT.AF_Commit;');
9359: l('');
9360: l(' END LOOP;');
9361: l(' log (''End Synchronizing Contact Points''); ');
9362: l(' END;');

Line 10319: l(' FND_CONCURRENT.AF_Commit;');

10315: END IF;
10316: END LOOP;
10317: l(' WHERE PARTY_ID=H_PARTY_ID(I);');
10318: l(' IF l_last_fetch THEN');
10319: l(' FND_CONCURRENT.AF_Commit;');
10320: l(' EXIT;');
10321: l(' END IF;');
10322: l(' FND_CONCURRENT.AF_Commit;');
10323: l(' END LOOP;');

Line 10322: l(' FND_CONCURRENT.AF_Commit;');

10318: l(' IF l_last_fetch THEN');
10319: l(' FND_CONCURRENT.AF_Commit;');
10320: l(' EXIT;');
10321: l(' END IF;');
10322: l(' FND_CONCURRENT.AF_Commit;');
10323: l(' END LOOP;');
10324: l(' END;');
10325: END IF;
10326: END;

Line 10585: l(' FND_CONCURRENT.AF_Commit;');

10581: l(';');
10582: END IF ;
10583:
10584: l(' IF l_last_fetch THEN');
10585: l(' FND_CONCURRENT.AF_Commit;');
10586: l(' EXIT;');
10587: l(' END IF;');
10588: l(' FND_CONCURRENT.AF_Commit;');
10589: l(' END LOOP;');

Line 10588: l(' FND_CONCURRENT.AF_Commit;');

10584: l(' IF l_last_fetch THEN');
10585: l(' FND_CONCURRENT.AF_Commit;');
10586: l(' EXIT;');
10587: l(' END IF;');
10588: l(' FND_CONCURRENT.AF_Commit;');
10589: l(' END LOOP;');
10590: l(' END;');
10591: END IF ;
10592: -- NO NEW TRANSFORMATIONS BUT THERE ARE SOME NEW DENORM ATTRIBUTES

Line 10654: l(' FND_CONCURRENT.AF_Commit;');

10650:
10651:
10652:
10653: l(' IF l_last_fetch THEN');
10654: l(' FND_CONCURRENT.AF_Commit;');
10655: l(' EXIT;');
10656: l(' END IF;');
10657: l(' FND_CONCURRENT.AF_Commit;');
10658: l(' END LOOP ; ');

Line 10657: l(' FND_CONCURRENT.AF_Commit;');

10653: l(' IF l_last_fetch THEN');
10654: l(' FND_CONCURRENT.AF_Commit;');
10655: l(' EXIT;');
10656: l(' END IF;');
10657: l(' FND_CONCURRENT.AF_Commit;');
10658: l(' END LOOP ; ');
10659: l(' END ; ');
10660: END IF ;
10661:

Line 10911: l(' FND_CONCURRENT.AF_Commit;');

10907: ELSE
10908: l(';');
10909: END IF ;
10910: l(' IF l_last_fetch THEN');
10911: l(' FND_CONCURRENT.AF_Commit;');
10912: l(' EXIT;');
10913: l(' END IF;');
10914: l(' FND_CONCURRENT.AF_Commit;');
10915: l(' END LOOP;');

Line 10914: l(' FND_CONCURRENT.AF_Commit;');

10910: l(' IF l_last_fetch THEN');
10911: l(' FND_CONCURRENT.AF_Commit;');
10912: l(' EXIT;');
10913: l(' END IF;');
10914: l(' FND_CONCURRENT.AF_Commit;');
10915: l(' END LOOP;');
10916: l(' END;');
10917: END IF ;
10918: -- NO NEW TRANSFORMATIONS BUT THERE ARE SOME NEW DENORM ATTRIBUTES

Line 10975: l(' FND_CONCURRENT.AF_Commit;');

10971: l('END ;');
10972: l('END LOOP ;');
10973:
10974: l(' IF l_last_fetch THEN');
10975: l(' FND_CONCURRENT.AF_Commit;');
10976: l(' EXIT;');
10977: l(' END IF;');
10978: l(' FND_CONCURRENT.AF_Commit;');
10979: l(' END LOOP ;');

Line 10978: l(' FND_CONCURRENT.AF_Commit;');

10974: l(' IF l_last_fetch THEN');
10975: l(' FND_CONCURRENT.AF_Commit;');
10976: l(' EXIT;');
10977: l(' END IF;');
10978: l(' FND_CONCURRENT.AF_Commit;');
10979: l(' END LOOP ;');
10980: l(' END ; ');
10981: END IF ;
10982: END;

Line 11227: l(' FND_CONCURRENT.AF_Commit;');

11223: ELSE
11224: l(';');
11225: END IF ;
11226: l(' IF l_last_fetch THEN');
11227: l(' FND_CONCURRENT.AF_Commit;');
11228: l(' EXIT;');
11229: l(' END IF;');
11230: l(' FND_CONCURRENT.AF_Commit;');
11231: l(' END LOOP;');

Line 11230: l(' FND_CONCURRENT.AF_Commit;');

11226: l(' IF l_last_fetch THEN');
11227: l(' FND_CONCURRENT.AF_Commit;');
11228: l(' EXIT;');
11229: l(' END IF;');
11230: l(' FND_CONCURRENT.AF_Commit;');
11231: l(' END LOOP;');
11232: l(' END;');
11233: END IF;
11234: ELSE

Line 11294: l(' FND_CONCURRENT.AF_Commit;');

11290:
11291:
11292:
11293: l(' IF l_last_fetch THEN');
11294: l(' FND_CONCURRENT.AF_Commit;');
11295: l(' EXIT;');
11296: l(' END IF;');
11297: l(' FND_CONCURRENT.AF_Commit;');
11298: l(' END LOOP ; ');

Line 11297: l(' FND_CONCURRENT.AF_Commit;');

11293: l(' IF l_last_fetch THEN');
11294: l(' FND_CONCURRENT.AF_Commit;');
11295: l(' EXIT;');
11296: l(' END IF;');
11297: l(' FND_CONCURRENT.AF_Commit;');
11298: l(' END LOOP ; ');
11299: l(' END ; ');
11300: END IF ;
11301:

Line 11590: l_bool := FND_CONCURRENT.wait_for_request(p_request_id,

11586:
11587: l_bool BOOLEAN;
11588:
11589: BEGIN
11590: l_bool := FND_CONCURRENT.wait_for_request(p_request_id,
11591: 60, 144000, uphase, ustatus, dphase, dstatus, message);
11592:
11593: IF dphase <> 'COMPLETE' and dstatus <> 'NORMAL' THEN
11594: return 'ERROR';