[Home] [Help]
1301: log('Wait on jobs >>'||get_time);
1302: dmp_parallel_jobs;
1303: end if;
1304: clean_up_jobs(null); --clean up done jobs
1305: if check_all_jobs_complete(g_parallel_jobs)=false then
1306: wait_on_jobs_sleep(p_options,p_job_status);
1307: /*looked at dbms_alert as a way to avoid active wait. but it looks like dbms_alert internally goes for active wait */
1308: end if;
1309: if g_debug then
1330: l_prev_time:=g_job_wait_time_small;
1331: end if;
1332: sleep(l_prev_time,null);
1333: check_jobs(g_parallel_jobs);
1334: if check_all_jobs_complete(g_parallel_jobs) then
1335: exit;
1336: end if;
1337: end loop;
1338: p_job_status:=g_parallel_jobs;
1354: log_n('Exception in check_jobs '||sqlerrm);
1355: raise;
1356: End;
1357:
1358: function check_all_jobs_complete(p_parallel_jobs parallel_job_tb) return boolean is
1359: Begin
1360: for i in 1..p_parallel_jobs.count loop
1361: if p_parallel_jobs(i).status <> 'success' and p_parallel_jobs(i).status <> 'error' then
1362: return false;
1363: end if;
1364: end loop;
1365: return true;
1366: Exception when others then
1367: log_n('Exception in check_all_jobs_complete '||sqlerrm);
1368: raise;
1369: End;
1370:
1371: procedure update_job_status(p_parallel_job in out nocopy parallel_job_r) is
1446: log_n('Exception in remove_pipe '||sqlerrm);
1447: End;
1448:
1449: /*
1450: we look at all_jobs and dba_jobs_running because when a job is launched, it takes some time
1451: for it to start.
1452: */
1453: function is_job_running(p_job_id number) return varchar2 is
1454: --
1451: for it to start.
1452: */
1453: function is_job_running(p_job_id number) return varchar2 is
1454: --
1455: cursor c1 is select 1 from all_jobs where job=p_job_id;
1456: l_status number;
1457: Begin
1458: open c1;
1459: fetch c1 into l_status;