2086: log('Total number of Data Workers deployed = ' || l_num_of_workers );
2087: log ('Data Workers only create/update data');
2088:
2089: --get request_id of this program
2090: l_request_id := FND_GLOBAL.conc_request_id ;
2091:
2092: -- Deploy Data Workers
2093:
2094: FIRST := TRUE ;
2582: if(index_cnt=null OR index_cnt=0) then
2583: insert into hz_dqm_stage_log(OPERATION, NUMBER_OF_WORKERS,WORKER_NUMBER,STEP,START_FLAG,START_TIME,END_FLAG,
2584: END_TIME,LAST_UPDATE_DATE, CREATION_DATE,CREATED_BY,LAST_UPDATED_BY,LAST_UPDATE_LOGIN )
2585: values ('ALTER_INDEX',1,1,'STAGED_TABLES','Y',sysdate,'Y',null,sysdate,sysdate,
2586: fnd_global.user_id,fnd_global.user_id,fnd_global.login_id);
2587: else
2588: update hz_dqm_stage_log set start_flag='Y',end_flag='Y',start_time=sysdate,
2589: last_update_date=sysdate,last_update_login=fnd_global.login_id
2590: where operation='ALTER_INDEX';
2585: values ('ALTER_INDEX',1,1,'STAGED_TABLES','Y',sysdate,'Y',null,sysdate,sysdate,
2586: fnd_global.user_id,fnd_global.user_id,fnd_global.login_id);
2587: else
2588: update hz_dqm_stage_log set start_flag='Y',end_flag='Y',start_time=sysdate,
2589: last_update_date=sysdate,last_update_login=fnd_global.login_id
2590: where operation='ALTER_INDEX';
2591: end if;
2592:
2593: ELSE
2604: if(index_cnt=null OR index_cnt=0) then
2605: insert into hz_dqm_stage_log(OPERATION, NUMBER_OF_WORKERS,WORKER_NUMBER,STEP,START_FLAG,START_TIME,END_FLAG,
2606: END_TIME,LAST_UPDATE_DATE, CREATION_DATE,CREATED_BY,LAST_UPDATED_BY,LAST_UPDATE_LOGIN)
2607: values ('ALTER_INDEX',1,1,'STAGED_TABLES','N',sysdate,'N',null,sysdate,sysdate,
2608: fnd_global.user_id,fnd_global.user_id,fnd_global.login_id);
2609: else
2610: update hz_dqm_stage_log set start_flag='N',end_flag='N',start_time=sysdate,
2611: last_update_date=sysdate,last_update_login=fnd_global.login_id
2612: where operation='ALTER_INDEX';
2607: values ('ALTER_INDEX',1,1,'STAGED_TABLES','N',sysdate,'N',null,sysdate,sysdate,
2608: fnd_global.user_id,fnd_global.user_id,fnd_global.login_id);
2609: else
2610: update hz_dqm_stage_log set start_flag='N',end_flag='N',start_time=sysdate,
2611: last_update_date=sysdate,last_update_login=fnd_global.login_id
2612: where operation='ALTER_INDEX';
2613: end if;
2614:
2615: END IF ;
2779:
2780: -- get request ids that did not complete
2781: Select request_id BULK COLLECT into l_sub_requests
2782: from Fnd_Concurrent_Requests R
2783: Where Parent_Request_Id = FND_GLOBAL.conc_request_id
2784: and (phase_code<>'C' or status_code<>'C');
2785:
2786: -- log these request_ids and set the return code of the parent concurrent program
2787: -- to 2 ie., ERROR