DBA Data[Home] [Help]

APPS.ISC_FS_TASK_ETL_PKG dependencies on BIS_COLLECTION_UTILITIES

Line 23: procedure bis_collection_utilities_log

19: g_uom_hours constant varchar2(10) := fnd_profile.value('CSF_UOM_HOURS');
20: g_time_base_to_hours number;
21:
22:
23: procedure bis_collection_utilities_log
24: ( m varchar2, indent number default null )
25: as
26: begin
27: --if indent is not null then

Line 34: bis_collection_utilities.log( substr(m,1,2000-(nvl(indent,0)*3)), nvl(indent,0) );

30: -- end loop;
31: --end if;
32: --dbms_output.put_line(substr(m,1,254));
33:
34: bis_collection_utilities.log( substr(m,1,2000-(nvl(indent,0)*3)), nvl(indent,0) );
35:
36: end bis_collection_utilities_log;
37:
38: procedure local_init

Line 36: end bis_collection_utilities_log;

32: --dbms_output.put_line(substr(m,1,254));
33:
34: bis_collection_utilities.log( substr(m,1,2000-(nvl(indent,0)*3)), nvl(indent,0) );
35:
36: end bis_collection_utilities_log;
37:
38: procedure local_init
39: as
40:

Line 78: bis_collection_utilities_log( g_pkg_name || '.' || p_proc_name ||

74: , p_message varchar2
75: )
76: as
77: begin
78: bis_collection_utilities_log( g_pkg_name || '.' || p_proc_name ||
79: ' #' || p_stmt_id || ' ' ||
80: p_message
81: , 3 );
82: end logger;

Line 161: l_refresh_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period(g_object_name));

157: l_refresh_date date;
158:
159: begin
160:
161: l_refresh_date := fnd_date.displaydt_to_date(bis_collection_utilities.get_last_refresh_period(g_object_name));
162: if l_refresh_date = g_global_start_date then
163: x_error_message := 'Incremental Load can only be run after a completed initial or incremental load';
164: return -1;
165: end if;

Line 214: bis_collection_utilities.get_last_user_attributes

210: l_last_load varchar2(150);
211:
212: begin
213:
214: bis_collection_utilities.get_last_user_attributes
215: ( g_object_name
216: , l_attributes
217: , l_count
218: );

Line 227: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);

223: l_last_load := 'X';
224: end if;
225:
226: if p_mode = 'initial_load' then
227: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
228: else
229: if g_ttr_ftf_rule = l_last_load then
230: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
231: else

Line 230: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);

226: if p_mode = 'initial_load' then
227: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
228: else
229: if g_ttr_ftf_rule = l_last_load then
230: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
231: else
232: bis_collection_utilities_log('Previous MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(l_last_load), 1);
233: bis_collection_utilities_log('Current MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
234: x_error_message := 'MTTR/FTFR Rule mismatch';

Line 232: bis_collection_utilities_log('Previous MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(l_last_load), 1);

228: else
229: if g_ttr_ftf_rule = l_last_load then
230: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
231: else
232: bis_collection_utilities_log('Previous MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(l_last_load), 1);
233: bis_collection_utilities_log('Current MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
234: x_error_message := 'MTTR/FTFR Rule mismatch';
235: return -1;
236: end if;

Line 233: bis_collection_utilities_log('Current MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);

229: if g_ttr_ftf_rule = l_last_load then
230: bis_collection_utilities_log('MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
231: else
232: bis_collection_utilities_log('Previous MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(l_last_load), 1);
233: bis_collection_utilities_log('Current MTTR/FTFR Rule: ' || get_tr_ftf_rule_meaning(g_ttr_ftf_rule), 1);
234: x_error_message := 'MTTR/FTFR Rule mismatch';
235: return -1;
236: end if;
237: end if;

Line 267: bis_collection_utilities_log( 'Begin Initial Load' );

263: begin
264:
265: local_init;
266:
267: bis_collection_utilities_log( 'Begin Initial Load' );
268:
269: l_stmt_id := 0;
270: if not bis_collection_utilities.setup( g_object_name ) then
271: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';

Line 270: if not bis_collection_utilities.setup( g_object_name ) then

266:
267: bis_collection_utilities_log( 'Begin Initial Load' );
268:
269: l_stmt_id := 0;
270: if not bis_collection_utilities.setup( g_object_name ) then
271: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';
272: logger( l_proc_name, l_stmt_id, l_error_message );
273: raise g_bis_setup_exception;
274: end if;

Line 271: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';

267: bis_collection_utilities_log( 'Begin Initial Load' );
268:
269: l_stmt_id := 0;
270: if not bis_collection_utilities.setup( g_object_name ) then
271: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';
272: logger( l_proc_name, l_stmt_id, l_error_message );
273: raise g_bis_setup_exception;
274: end if;
275:

Line 287: bis_collection_utilities_log( 'From ' || fnd_date.date_to_displaydt(l_collect_from_date), 1 );

283:
284: l_collect_from_date := g_global_start_date;
285: l_collect_to_date := sysdate;
286:
287: bis_collection_utilities_log( 'From ' || fnd_date.date_to_displaydt(l_collect_from_date), 1 );
288: bis_collection_utilities_log( 'To ' || fnd_date.date_to_displaydt(l_collect_to_date), 1 );
289:
290: -- check MTTR/FTFR district rule
291: l_stmt_id := 20;

Line 288: bis_collection_utilities_log( 'To ' || fnd_date.date_to_displaydt(l_collect_to_date), 1 );

284: l_collect_from_date := g_global_start_date;
285: l_collect_to_date := sysdate;
286:
287: bis_collection_utilities_log( 'From ' || fnd_date.date_to_displaydt(l_collect_from_date), 1 );
288: bis_collection_utilities_log( 'To ' || fnd_date.date_to_displaydt(l_collect_to_date), 1 );
289:
290: -- check MTTR/FTFR district rule
291: l_stmt_id := 20;
292: if check_district_rule

Line 318: bis_collection_utilities_log( 'Events table truncated', 1 );

314: logger( l_proc_name, l_stmt_id, l_error_message );
315: raise l_exception;
316: end if;
317:
318: bis_collection_utilities_log( 'Events table truncated', 1 );
319:
320: -- truncate the party merge events table
321: l_stmt_id := 50;
322: if truncate_table

Line 330: bis_collection_utilities_log( 'Party Merge Events table truncated', 1 );

326: logger( l_proc_name, l_stmt_id, l_error_message );
327: raise l_exception;
328: end if;
329:
330: bis_collection_utilities_log( 'Party Merge Events table truncated', 1 );
331:
332: -- enable event logging
333: l_stmt_id := 60;
334: if isc_fs_event_log_etl_pkg.enable_events

Line 340: bis_collection_utilities_log( 'Event logging enabled', 1 );

336: logger( l_proc_name, l_stmt_id, l_error_message );
337: raise l_exception;
338: end if;
339:
340: bis_collection_utilities_log( 'Event logging enabled', 1 );
341:
342: -- truncate the isc_fs_tasks_f fact table
343: l_stmt_id := 70;
344: if truncate_table

Line 352: bis_collection_utilities_log( 'Task base summary table truncated', 1 );

348: logger( l_proc_name, l_stmt_id, l_error_message );
349: raise l_exception;
350: end if;
351:
352: bis_collection_utilities_log( 'Task base summary table truncated', 1 );
353:
354: -- truncate the isc_fs_task_assignmnts_f fact table
355: l_stmt_id := 80;
356: if truncate_table

Line 364: bis_collection_utilities_log( 'Task Assignments base summary table truncated', 1 );

360: logger( l_proc_name, l_stmt_id, l_error_message );
361: raise l_exception;
362: end if;
363:
364: bis_collection_utilities_log( 'Task Assignments base summary table truncated', 1 );
365:
366: -- R12 dep/arr
367: -- attempt to truncate obsolete isc_fs_dep_arr_tasks_f table,
368: -- ignore any errors as table may not exist.

Line 374: bis_collection_utilities_log( 'Obsolete Departure/Arrival Task base summary table truncated', 1 );

370: if truncate_table
371: ( l_isc_schema
372: , 'ISC_FS_DEP_ARR_TASKS_F'
373: , l_error_message ) = 0 then
374: bis_collection_utilities_log( 'Obsolete Departure/Arrival Task base summary table truncated', 1 );
375: end if;
376:
377: -- truncate the isc_fs_capacity_f fact table
378: l_stmt_id := 95;

Line 387: bis_collection_utilities_log( 'Capacity base summary table truncated', 1 );

383: logger( l_proc_name, l_stmt_id, l_error_message );
384: raise l_exception;
385: end if;
386:
387: bis_collection_utilities_log( 'Capacity base summary table truncated', 1 );
388: -- R12 dep/arr
389:
390: -- insert into base fact tables
391: l_stmt_id := 100;

Line 1353: bis_collection_utilities_log( l_rowcount || ' rows inserted into base summaries', 1 );

1349: l_rowcount := sql%rowcount;
1350:
1351: commit;
1352:
1353: bis_collection_utilities_log( l_rowcount || ' rows inserted into base summaries', 1 );
1354:
1355: l_stmt_id := 110;
1356: bis_collection_utilities.wrapup( p_status => true
1357: , p_period_from => l_collect_from_date

Line 1356: bis_collection_utilities.wrapup( p_status => true

1352:
1353: bis_collection_utilities_log( l_rowcount || ' rows inserted into base summaries', 1 );
1354:
1355: l_stmt_id := 110;
1356: bis_collection_utilities.wrapup( p_status => true
1357: , p_period_from => l_collect_from_date
1358: , p_period_to => l_collect_to_date
1359: , p_count => l_rowcount
1360: , p_attribute1 => g_ttr_ftf_rule

Line 1363: bis_collection_utilities_log('End Initial Load');

1359: , p_count => l_rowcount
1360: , p_attribute1 => g_ttr_ftf_rule
1361: );
1362:
1363: bis_collection_utilities_log('End Initial Load');
1364:
1365: errbuf := null;
1366: retcode := g_success;
1367:

Line 1373: bis_collection_utilities_log('End Initial Load with Error');

1369: when g_bis_setup_exception then
1370: rollback;
1371: errbuf := l_error_message;
1372: retcode := g_error;
1373: bis_collection_utilities_log('End Initial Load with Error');
1374:
1375: when l_exception then
1376: rollback;
1377: if l_error_message is null then

Line 1380: bis_collection_utilities.wrapup( p_status => false

1376: rollback;
1377: if l_error_message is null then
1378: l_error_message := substr(sqlerrm,1,4000);
1379: end if;
1380: bis_collection_utilities.wrapup( p_status => false
1381: , p_message => l_error_message
1382: , p_period_from => l_collect_from_date
1383: , p_period_to => l_collect_to_date
1384: );

Line 1387: bis_collection_utilities_log('End Initial Load with Error');

1383: , p_period_to => l_collect_to_date
1384: );
1385: errbuf := l_error_message;
1386: retcode := g_error;
1387: bis_collection_utilities_log('End Initial Load with Error');
1388:
1389: when others then
1390: rollback;
1391: if l_error_message is null then

Line 1395: bis_collection_utilities.wrapup( p_status => false

1391: if l_error_message is null then
1392: l_error_message := substr(sqlerrm,1,4000);
1393: end if;
1394: logger( l_proc_name, l_stmt_id, l_error_message );
1395: bis_collection_utilities.wrapup( p_status => false
1396: , p_message => l_error_message
1397: , p_period_from => l_collect_from_date
1398: , p_period_to => l_collect_to_date
1399: );

Line 1402: bis_collection_utilities_log('End Initial Load with Error');

1398: , p_period_to => l_collect_to_date
1399: );
1400: errbuf := l_error_message;
1401: retcode := g_error;
1402: bis_collection_utilities_log('End Initial Load with Error');
1403:
1404: end initial_load;
1405:
1406: procedure incremental_load

Line 1431: bis_collection_utilities_log( 'Begin Incremental Load' );

1427: begin
1428:
1429: local_init;
1430:
1431: bis_collection_utilities_log( 'Begin Incremental Load' );
1432:
1433: l_stmt_id := 0;
1434: if not bis_collection_utilities.setup( g_object_name ) then
1435: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';

Line 1434: if not bis_collection_utilities.setup( g_object_name ) then

1430:
1431: bis_collection_utilities_log( 'Begin Incremental Load' );
1432:
1433: l_stmt_id := 0;
1434: if not bis_collection_utilities.setup( g_object_name ) then
1435: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';
1436: logger( l_proc_name, l_stmt_id, l_error_message );
1437: raise g_bis_setup_exception;
1438: end if;

Line 1435: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';

1431: bis_collection_utilities_log( 'Begin Incremental Load' );
1432:
1433: l_stmt_id := 0;
1434: if not bis_collection_utilities.setup( g_object_name ) then
1435: l_error_message := 'Error in BIS_COLLECTION_UTILITIES.Setup';
1436: logger( l_proc_name, l_stmt_id, l_error_message );
1437: raise g_bis_setup_exception;
1438: end if;
1439:

Line 1449: bis_collection_utilities_log( 'From: ' || fnd_date.date_to_displaydt(l_collect_from_date), 1 );

1445: end if;
1446: l_collect_from_date := l_collect_to_date + 1/86400;
1447: l_collect_to_date := sysdate;
1448:
1449: bis_collection_utilities_log( 'From: ' || fnd_date.date_to_displaydt(l_collect_from_date), 1 );
1450: bis_collection_utilities_log( 'To: ' || fnd_date.date_to_displaydt(l_collect_to_date), 1 );
1451:
1452: -- check MTTR/FTFR district rule
1453: l_stmt_id := 20;

Line 1450: bis_collection_utilities_log( 'To: ' || fnd_date.date_to_displaydt(l_collect_to_date), 1 );

1446: l_collect_from_date := l_collect_to_date + 1/86400;
1447: l_collect_to_date := sysdate;
1448:
1449: bis_collection_utilities_log( 'From: ' || fnd_date.date_to_displaydt(l_collect_from_date), 1 );
1450: bis_collection_utilities_log( 'To: ' || fnd_date.date_to_displaydt(l_collect_to_date), 1 );
1451:
1452: -- check MTTR/FTFR district rule
1453: l_stmt_id := 20;
1454: if check_district_rule

Line 1480: bis_collection_utilities_log( 'Staging table truncated', 1 );

1476: logger( l_proc_name, l_stmt_id, l_error_message );
1477: raise l_exception;
1478: end if;
1479:
1480: bis_collection_utilities_log( 'Staging table truncated', 1 );
1481:
1482: -- insert into staging table from events table
1483: l_stmt_id := 40;
1484: insert into isc_fs_events_stg

Line 1505: bis_collection_utilities_log( l_rowcount || ' rows inserted into staging table from events', 1 );

1501:
1502: l_rowcount := sql%rowcount;
1503: commit;
1504:
1505: bis_collection_utilities_log( l_rowcount || ' rows inserted into staging table from events', 1 );
1506:
1507: -- insert into staging table from party merge events table
1508: l_stmt_id := 50;
1509: insert into isc_fs_events_stg

Line 1528: bis_collection_utilities_log( l_rowcount || ' rows inserted into staging table from party mearge events', 1 );

1524:
1525: l_rowcount := sql%rowcount;
1526: commit;
1527:
1528: bis_collection_utilities_log( l_rowcount || ' rows inserted into staging table from party mearge events', 1 );
1529:
1530: -- gather stats for staging table
1531: l_stmt_id := 60;
1532: if gather_statistics

Line 1540: bis_collection_utilities_log( 'Gathered stats for staging table', 1 );

1536: logger( l_proc_name, l_stmt_id, l_error_message );
1537: raise l_exception;
1538: end if;
1539:
1540: bis_collection_utilities_log( 'Gathered stats for staging table', 1 );
1541:
1542: -- do the merge into isc_fs_task_assignmnts_f
1543: l_stmt_id := 70;
1544: merge into isc_fs_task_assignmnts_f o

Line 1707: bis_collection_utilities_log( l_rowcount || ' rows merged into task assignments base summary', 1 );

1703: );
1704:
1705: l_rowcount := sql%rowcount;
1706:
1707: bis_collection_utilities_log( l_rowcount || ' rows merged into task assignments base summary', 1 );
1708:
1709: -- do the merge into isc_fs_tasks_f
1710: l_stmt_id := 80;
1711: merge into isc_fs_tasks_f o

Line 2493: bis_collection_utilities_log( l_temp_rowcount || ' rows merged into tasks base summary', 1 );

2489: );
2490:
2491: l_temp_rowcount := sql%rowcount;
2492:
2493: bis_collection_utilities_log( l_temp_rowcount || ' rows merged into tasks base summary', 1 );
2494:
2495: l_rowcount := l_rowcount + l_temp_rowcount;
2496:
2497: -- R12 dep/arr

Line 2615: bis_collection_utilities_log( l_temp_rowcount || ' rows merged into capacity base summary', 1 );

2611: -- R12 dep/arr
2612:
2613: l_temp_rowcount := sql%rowcount;
2614:
2615: bis_collection_utilities_log( l_temp_rowcount || ' rows merged into capacity base summary', 1 );
2616:
2617: l_rowcount := l_rowcount + l_temp_rowcount;
2618:
2619: -- delete processed rows from events table

Line 2626: bis_collection_utilities_log( l_temp_rowcount || ' rows deleted from events table', 1 );

2622: where rowid in ( select event_rowid from isc_fs_events_stg where source = 1 );
2623:
2624: l_temp_rowcount := sql%rowcount;
2625:
2626: bis_collection_utilities_log( l_temp_rowcount || ' rows deleted from events table', 1 );
2627:
2628: -- delete processed rows from party merge events table
2629: l_stmt_id := 110;
2630: delete from isc_fs_party_merge_events

Line 2635: bis_collection_utilities_log( l_temp_rowcount || ' rows deleted from party merge events table', 1 );

2631: where rowid in ( select event_rowid from isc_fs_events_stg where source = 2 );
2632:
2633: l_temp_rowcount := sql%rowcount;
2634:
2635: bis_collection_utilities_log( l_temp_rowcount || ' rows deleted from party merge events table', 1 );
2636:
2637: commit;
2638:
2639: bis_collection_utilities_log( 'Cleaning up..', 1 );

Line 2639: bis_collection_utilities_log( 'Cleaning up..', 1 );

2635: bis_collection_utilities_log( l_temp_rowcount || ' rows deleted from party merge events table', 1 );
2636:
2637: commit;
2638:
2639: bis_collection_utilities_log( 'Cleaning up..', 1 );
2640:
2641: -- attempt (no fail) to truncate party merge events table is zero rows
2642: l_stmt_id := 120;
2643: begin

Line 2659: bis_collection_utilities_log( 'Party merge events table truncated', 2 );

2655: , l_error_message ) <> 0 then
2656: logger( l_proc_name, l_stmt_id, l_error_message );
2657: raise l_exception;
2658: end if;
2659: bis_collection_utilities_log( 'Party merge events table truncated', 2 );
2660: else
2661: bis_collection_utilities_log( l_temp_rowcount || ' new unprocessed rows party merge events table', 2 );
2662: end if;
2663:

Line 2661: bis_collection_utilities_log( l_temp_rowcount || ' new unprocessed rows party merge events table', 2 );

2657: raise l_exception;
2658: end if;
2659: bis_collection_utilities_log( 'Party merge events table truncated', 2 );
2660: else
2661: bis_collection_utilities_log( l_temp_rowcount || ' new unprocessed rows party merge events table', 2 );
2662: end if;
2663:
2664: exception
2665: when l_exception then

Line 2668: bis_collection_utilities_log( 'Unable to lock party merge events table at this time', 2 );

2664: exception
2665: when l_exception then
2666: raise l_exception;
2667: when l_resource_busy then
2668: bis_collection_utilities_log( 'Unable to lock party merge events table at this time', 2 );
2669: when others then
2670: raise;
2671: end;
2672:

Line 2685: bis_collection_utilities_log( 'Staging table truncated', 2 );

2681: logger( l_proc_name, l_stmt_id, l_error_message );
2682: raise l_exception;
2683: end if;
2684:
2685: bis_collection_utilities_log( 'Staging table truncated', 2 );
2686:
2687: l_stmt_id := 140;
2688: bis_collection_utilities.wrapup( p_status => true
2689: , p_period_from => l_collect_from_date

Line 2688: bis_collection_utilities.wrapup( p_status => true

2684:
2685: bis_collection_utilities_log( 'Staging table truncated', 2 );
2686:
2687: l_stmt_id := 140;
2688: bis_collection_utilities.wrapup( p_status => true
2689: , p_period_from => l_collect_from_date
2690: , p_period_to => l_collect_to_date
2691: , p_count => l_rowcount
2692: , p_attribute1 => g_ttr_ftf_rule

Line 2695: bis_collection_utilities_log('End Incremental Load');

2691: , p_count => l_rowcount
2692: , p_attribute1 => g_ttr_ftf_rule
2693: );
2694:
2695: bis_collection_utilities_log('End Incremental Load');
2696:
2697: errbuf := null;
2698: retcode := g_success;
2699:

Line 2705: bis_collection_utilities_log('End Incremential Load with Error');

2701: when g_bis_setup_exception then
2702: rollback;
2703: errbuf := l_error_message;
2704: retcode := g_error;
2705: bis_collection_utilities_log('End Incremential Load with Error');
2706:
2707: when l_exception then
2708: rollback;
2709: if l_error_message is null then

Line 2712: bis_collection_utilities.wrapup( p_status => false

2708: rollback;
2709: if l_error_message is null then
2710: l_error_message := substr(sqlerrm,1,4000);
2711: end if;
2712: bis_collection_utilities.wrapup( p_status => false
2713: , p_message => l_error_message
2714: , p_period_from => l_collect_from_date
2715: , p_period_to => l_collect_to_date
2716: );

Line 2719: bis_collection_utilities_log('End Incremential Load with Error');

2715: , p_period_to => l_collect_to_date
2716: );
2717: errbuf := l_error_message;
2718: retcode := g_error;
2719: bis_collection_utilities_log('End Incremential Load with Error');
2720:
2721: when others then
2722: rollback;
2723: if l_error_message is null then

Line 2727: bis_collection_utilities.wrapup( p_status => false

2723: if l_error_message is null then
2724: l_error_message := substr(sqlerrm,1,4000);
2725: end if;
2726: logger( l_proc_name, l_stmt_id, l_error_message );
2727: bis_collection_utilities.wrapup( p_status => false
2728: , p_message => l_error_message
2729: , p_period_from => l_collect_from_date
2730: , p_period_to => l_collect_to_date
2731: );

Line 2734: bis_collection_utilities_log('End Incremential Load with Error');

2730: , p_period_to => l_collect_to_date
2731: );
2732: errbuf := l_error_message;
2733: retcode := g_error;
2734: bis_collection_utilities_log('End Incremential Load with Error');
2735:
2736: end incremental_load;
2737:
2738: end isc_fs_task_etl_pkg;