From 60b218d21161ddb232431c2036c0a78430504cde Mon Sep 17 00:00:00 2001 From: Grzegorz Michalski Date: Thu, 26 Feb 2026 20:37:03 +0100 Subject: [PATCH] Hotfix - Add filtering for successful workflows in archival queries --- .../REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb b/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb index 8ed77d1..1c9f880 100644 --- a/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb +++ b/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb @@ -166,6 +166,7 @@ AS join CT_MRDS.a_workflow_history h on s.a_workflow_history_key = h.a_workflow_history_key where ' || GET_ARCHIVAL_WHERE_CLAUSE(vSourceFileConfig) || ' + and h.WORKFLOW_SUCCESSFUL = ''Y'' group by file$name, file$path, to_char(h.workflow_start,''yyyy''), to_char(h.workflow_start,''mm'')' ; @@ -182,11 +183,11 @@ AS join CT_MRDS.A_SOURCE_FILE_RECEIVED r on s.file$name = r.source_file_name and r.a_source_file_config_key = '||pSourceFileConfigKey||' - and r.PROCESSING_STATUS = ''INGESTED'' join CT_MRDS.a_workflow_history h on s.a_workflow_history_key = h.a_workflow_history_key and to_char(h.workflow_start,''yyyy'') = '''||ym_loop.year||''' and to_char(h.workflow_start,''mm'') = '''||ym_loop.month||''' + and h.WORKFLOW_SUCCESSFUL = ''Y'' ' ; vUri := CT_MRDS.FILE_MANAGER.GET_BUCKET_URI('ARCHIVE')||'ARCHIVE/'||vSourceFileConfig.A_SOURCE_KEY||'/'||vSourceFileConfig.TABLE_ID||'/PARTITION_YEAR='||ym_loop.year||'/PARTITION_MONTH='||ym_loop.month||'/';