...
All information that is required to be shown to user and that is needed for proper removing file from processing queue is available on different steps of file routing, we just need . ORCH tables in PACE_MASTERDBO schema can be used to store this information in one place, which will be makes it easy to handle and update. For that we can use ORCH tables in PACE_MASTERDBO schema. The CorrelationID for storing stored information about a file can be used is the same as used for trigger file name that ndfa sends to ndfa_exec, GUID with DATA suffix, i.e. B812JJ64DU6DEVPSDATA.
When the user queries data about all incoming files that were provided on the region (from EJM MT External Data tab) EJM MT shows data from ORCH_REQUEST_DEF and ORCH_QUEUE tables where ORCH_QUEUE.CREATE_DATE is within queried time interval and ORCH_REQUEST_DEF.CORRELATION_ID has ‘DATA’ as four last characters.
Data that is suggested to store stored is:
- file File correlation id – to correlate incoming file and all information about this file, same as signal correlation id.
- remote Remote file name – original file name of file.
- Added timestamp – timestamp of file acceptance on region. Combined with remote file name will allow user to understand what is this file, if it should or not be processed.
- status Status – to store information about status of file processing, if file was acknowledged as file for some of workflows and pending for processing, if file was already processed, if file is not acknowledged as data for any workflow on region and if file processing was canceled before actual file load. Needed for user to be able to understand what happened with the file.
- Source signal correlation id – only for files that were created from incoming file as result of profile_executor processing.
- Process wrf + wrf + event names and process wrf + wrf + event corrIds for already processed files – information about procWrf/wrf/event that will process/already processed file. Needed for user to understand what will happen/what happened with file.
- Sent by – must store information about user who sent this file (if file was sent through MCC/MCE) or owner of the file (for instance sitesee adds itself as owner of the file to file properties) or profile under which this file was sent to processing
- Source file name – name of source file from which this file was generated – only for files that are created from external data as part of profile_executor processing.
- Consumed/cancelation timestamps – timestamps when file was processed or file record was deleted from queue for processing
- Cancelation correlation id – correlation id for RTR for removing file from queue for processing
- Canceled as child flag – if file was canceled as child of incoming file. For instance, if user sends incorrect SRM file that is processed in profile_executor workflow and creates GenericSMF and Rating files for profiled generic load user must be able to cancel all files that were created from source SRM file.
- isBundleTrigger flag – if file is bundle trigger and instantiated workflow
- triggeredWrofklowCorrId – correltation id of workflow that is triggered by this file if file is bundle trigger
- genericloadprofile – name of profile if file belongs to specific generic load profile
- ErrorDescr – detailted reason of failed/NACK status
- Queue instance – specifies to what queue file belongs to.
Table with data description
Here is list of information which is supposed to be stored, corresponding DB fields for data storage, logic of data origin and possible values.
Possible scenarios
Incoming file that has no corresponding workflow on region
File UnexpectedIncomingData.dat arrives on region, sent by user VPELEVIN through MCC on 2018-09-11 at 09:00:00
ndfa sends trigger file to ndfa_exec.
ndfa_exec does not find any matching .map or .datamap files for this file.
ndfa_exec creates record in DB for this file with signal correlation id (corrId from trigger file name), NACK status, owner, added timestamp and remote file name and finishes with failed status.
Data for this file in DB will look like this:
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
UnexpectedIncomingData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
VPELEVIN
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
BBC734FB238E8BE3DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
NACK
...
ORCH_QUEUE.CREATE_DATE
...
20180911T090000
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T090000
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-418
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_BBC734FB238E8BE3DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
BBC734FB238E8BE3DATA
Incoming file that has corresponding workflow on region
File ExpectedIncomingData.dat arrives on region, someone places file in ndfa/incoming folder through SMC on 2018-09-10 at 07-01-05.
ndfa sends trigger file to ndfa_exec.
ndfa_exec finds matching .map for this file – workflow load_files with subprocess load_dat_files and task load_expected should process this file.
ndfa_exec creates setEvent CM and sends it to control_message stream
ndfa_exec creates record in DB for this file with signal correlation id, ACK status, added timestamp, owner (NA – because there is no way to tell source of file), remote file name and processWrf+wrf+event names.
At this moment record in DB looks like this
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
ExpectedIncomingData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
NA
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
AA4734CB238E8BE3DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
ACK
...
ORCH_QUEUE.CREATE_DATE
...
20180910T070105
...
ORCH_QUEUE.UPDATE_DATE
...
20180910T070105
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:load_files:workflow:load_dat_files:event:load_expected
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-200
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_AA4734CB238E8BE3DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
AA4734CB238E8BE3DATA
Corresponding workflow launches by RTR from third source, execwkfl gets to waitEvent step in workflow, checks if WAITEVENTS record has information about waiting file, finds this file, passes file to processing and updates DB record about this file (by signal correlation id that is written in WAITEVENTS record) with SUCCESS status, procWrfCorrId+eventCorrId. Consumed timestamp is updated automatically on DB records update.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
ExpectedIncomingData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
NA
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
AA4734CB238E8BE3DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
SUCCSESS
...
ORCH_QUEUE.CREATE_DATE
...
20180910T070105
...
ORCH_QUEUE.UPDATE_DATE
...
20180910T083517
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:load_files:workflow:load_dat_files:event:load_expected: processcorrelationid:B812LD60TOJVFBAB:correlationid:812FJ53HHQJCKWO
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
3591980
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_AA4734CB238E8BE3DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
AA4734CB238E8BE3DATA
Incoming file that has corresponding workflow on region being canceled before processing
File newExpectedIncomingData.dat arrives on region, sitesee places file in ndfa/incoming folder on 2018-09-11 at 09-14-03.
ndfa sends trigger file to ndfa_exec.
ndfa_exec finds matching .map for this file.
ndfa_exec creates setEvent CM and sends it to control_message stream
ndfa_exec creates record in DB for this file with signal correlation id, ACK status, added timestamp, owner, remote file name and processWrf+wrf+event names.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
newExpectedIncomingData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
sitesee
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
BA4717CB238E8BD4DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
ACK
...
ORCH_QUEUE.CREATE_DATE
...
20180911T091403
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T091403
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:load_files:workflow:load_dat_files:event:load_expected
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-200
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_BA4717CB238E8BD4DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
BA4717CB238E8BD4DATA
Before corresponding workflow launches for file processing at 09-18-05 user decides to cancel file processing and either cancels file processing through EJM MT or drops RTR for execwkfl where Action is CANCELEVENT and SignalCorrelationId is file signal correlation Id. RTR correlation Id is 2LD60KM3MXVSU002.
Execwkfl gets information about this file from DB – by signal correlation id – reads name of processWrf, gets this processWrf WAITEVETNS record, deletes this file from queue and updates DB record about file with FAILED status, cancelCorrId (canceled timestamp is updated automatically) and ErrorDescription stating that File processing was canceled.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
newExpectedIncomingData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
sitesee
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
BA4717CB238E8BD4DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
FAILED
...
ORCH_QUEUE.CREATE_DATE
...
20180911T091403
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T091805
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:load_files:workflow:load_dat_files:event:load_expected:cancelcorrelationid:2LD60KM3MXVSU002:ErrorDescr:File processing was canceled.
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-418
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_BA4717CB238E8BD4DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
BA4717CB238E8BD4DATA
Incoming file that has corresponding workflow and is bundle trigger
File InstantiateWorkflow.dat arrives on region, user MOLIVEIRA sends file through MCC on 2018-09-11 at 10-11-11.
ndfa sends trigger file to ndfa_exec.
ndfa_exec finds matching .map for this file, workflow name is autostart_wrf, task is load_file, no subprocess.
ndfa_exec creates CM for launching wrf and sends it to control_message stream.
ndfa_exec creates setEvent CM and sends it to control_message stream.
ndfa_exec creates record in DB for this file with signal correlation id, ACK status, added timestamp, owner, remote file name, triggeredWorkflowCorrId and processWrf+wrf+event names.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
InstantiateWorkflow.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
sitesee
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
B81AJJ840M6GVQQQDATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
ACK
...
ORCH_QUEUE.CREATE_DATE
...
20180911T101111
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T101111
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:autostart_wrf:workflow::event:load_file:triggeredWorkflowCorrId:B81AJI92GLCLWLRO:isBundleTrigger:Y
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-200
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_B81AJJ840M6GVQQQDATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
B81AJJ840M6GVQQQDATA
Launched workflow launches by RTR from ndfa_exec, execwkfl gets to waitEvent step, checks if WAITEVENTS record has information about waiting file, finds this file, passes file to processing and updates DB record about this file (by signal correlation id that is written in WAITEVENTS record) with SUCCESS status, procWrfCorrId+wrfCorrId+eventCorrId. Consumed timestamp is updated automatically on DB records update.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
InstantiateWorkflow.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
sitesee
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
B81AJJ840M6GVQQQDATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
SUCCSESS
...
ORCH_QUEUE.CREATE_DATE
...
20180911T101111
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T101111
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:autostart_wrf:workflow::event:load_file:triggeredWorkflowCorrId:B81AJI92GLCLWLRO:processcorrelationid:B81AJI92GLCLWLRO:correlationid:755C564B32B0EBB8
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
3592012
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_B81AJJ840M6GVQQQDATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
B81AJJ840M6GVQQQDATA
Incoming file that has corresponding profile
File with name profileData.dat arrives on region by sitesee delivery at 04:17:53 on 2018-09-11.
ndfa sends trigger file to ndfa_exec.
ndfa_exec finds matching .datamap for this file.
ndfa_exec creates CM for launching profile_executor with this file as source and sends it to control_message stream.
ndfa_exec creates record in DB for this file with signal correlation id, SUCCSESS status, added timestamp, owner, remote file name, processWrf+wrf+event names and corrIds.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
profileData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
sitesee
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
B81AJI21HCXDCPWRDATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
SUCCSESS
...
ORCH_QUEUE.CREATE_DATE
...
20180911T041753
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T041753
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:eagle_wrf_generic_load_profile_executor:workflow::event::triggeredWorkflowCorrId:C92AJI21HCXDCPWD:isBundleTrigger:Y:genericloadprofile:ent_smf_profile
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-200
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_B81AJI21HCXDCPWRDATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
B81AJI21HCXDCPWRDATA
Profile_executor translates file and on send_to_wrf step for each resulting file creates setEvent CM and creates DB record with file correlationId, ACK status, source signal correlation id, source file name, remote file name, owner (profile name), processWrf+wrf+event names.
Two records are created as two files are created from source file – one for Entity and one for SMF loaders in generic load.
ORCH_REQUEST_DEF.BUS_TASK_ID | B81AJF60K28OLTCLDATA_entsmfprofileGENERICSMF.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | B81AJF60K28OLTCLDATA |
ORCH_REQUEST_DEF.CF_NAME | B81AJI21HCXDCPWRDATA |
ORCH_REQUEST_DEF.PROC_STATUS | ACK |
ORCH_QUEUE.CREATE_DATE | 20180911T041852 |
ORCH_QUEUE.UPDATE_DATE | 20180911T041852 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:eagle_wrf_generic_load_profile_executor:workflow::event::triggeredWorkflowCorrId:C92AJI21HCXDCPWD:isBundleTrigger:Y:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | -200 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_B81AJF60K28OLTCLDATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | B81AJF60K28OLTCLDATA |
ORCH_REQUEST_DEF.BUS_TASK_ID | B81AJF60K28OSD04DATA_entsmfprofileGENERICENTITY.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | B81AJF60K28OSD04DATA |
ORCH_REQUEST_DEF.CF_NAME | B81AJI21HCXDCPWRDATA |
ORCH_REQUEST_DEF.PROC_STATUS | ACK |
ORCH_QUEUE.CREATE_DATE | 20180911T041853 |
ORCH_QUEUE.UPDATE_DATE | 20180911T041853 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:ent_smf_profile_wrf_generic_load:workflow: ent_smf_profile_wrf_load_entity:event:load_entity:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | -200 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_B81AJF60K28OSD04DATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | B81AJF60K28OSD04DATA |
When corresponding profiled generic load is instantiated and comes to corresponding waitEvent step – each file gets update with SUCCESS status, processWrf+wrf+event corrIds.
ORCH_REQUEST_DEF.BUS_TASK_ID | B81AJF60K28OLTCLDATA_entsmfprofileGENERICSMF.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | B81AJF60K28OLTCLDATA |
ORCH_REQUEST_DEF.CF_NAME | B81AJI21HCXDCPWRDATA |
ORCH_REQUEST_DEF.PROC_STATUS | SUCCESS |
ORCH_QUEUE.CREATE_DATE | 20180911T041852 |
ORCH_QUEUE.UPDATE_DATE | 20180911T041852 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:eagle_wrf_generic_load_profile_executor:workflow::event::triggeredWorkflowCorrId:C92AJI21HCXDCPWD:isBundleTrigger:Y:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat:processcorrelationid:DDDB8E3DC80305B4:correlationid:1C5D17D74707DFFF |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | 3591989 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_B81AJF60K28OLTCLDATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | B81AJF60K28OLTCLDATA |
ORCH_REQUEST_DEF.BUS_TASK_ID | B81AJF60K28OSD04DATA_entsmfprofileGENERICENTITY.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | B81AJF60K28OSD04DATA |
ORCH_REQUEST_DEF.CF_NAME | B81AJI21HCXDCPWRDATA |
ORCH_REQUEST_DEF.PROC_STATUS | SUCCESS |
ORCH_QUEUE.CREATE_DATE | 20180911T041853 |
ORCH_QUEUE.UPDATE_DATE | 20180911T041853 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:ent_smf_profile_wrf_generic_load:workflow: ent_smf_profile_wrf_load_entity:event:load_entity:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat:processcorrelationid:DDDB8E3DC80305C:correlationid:1C5D17D74707DFFA |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | 3591989 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_B81AJF60K28OSD04DATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | B81AJF60K28OSD04DATA |
Incoming file that has corresponding profile but processing getting canceled before results load
File with name profileData.dat arrives on region by sitesee delivery at 11:23:41 on 2018-09-11.
ndfa sends trigger file to ndfa_exec.
ndfa_exec finds matching .datamap for this file.
ndfa_exec creates CM for launching profile_executor with this file as source and sends it to control_message stream.
ndfa_exec creates record in DB for this file with signal correlation id, SUCCSESS status, added timestamp, owner, remote file name, processWrf+wrf+event names and corrIds.
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
profileData.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
sitesee
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
1AFCF23B87F15D39DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
ORCH_REQUEST_DEF.PROC_STATUS
...
SUCCSESS
...
ORCH_QUEUE.CREATE_DATE
...
20180911T112341
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T112341
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:eagle_wrf_generic_load_profile_executor:workflow::event::triggeredWorkflowCorrId:ED41D0A74E685579:isBundleTrigger:Y:genericloadprofile:ent_smf_profile
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-200
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_1AFCF23B87F15D39DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
1AFCF23B87F15D39DATA
Profile_executor translates file and on send_to_wrf step for each resulting file creates setEvent CM and creates DB record with file correlationId, ACK status, source signal correlation id, source file name, remote file name, owner (profile name), processWrf+wrf+event names.
ORCH_REQUEST_DEF.BUS_TASK_ID | B81AJF60K28OLTCLDATA_entsmfprofileGENERICSMF.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | CE8DE524094D2F05DATA |
ORCH_REQUEST_DEF.CF_NAME | 1AFCF23B87F15D39DATA |
ORCH_REQUEST_DEF.PROC_STATUS | ACK |
ORCH_QUEUE.CREATE_DATE | 20180911T112541 |
ORCH_QUEUE.UPDATE_DATE | 20180911T112541 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:eagle_wrf_generic_load_profile_executor:workflow::event::triggeredWorkflowCorrId:C92AJI21HCXDCPWD:isBundleTrigger:Y:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | -200 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_CE8DE524094D2F05DATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | CE8DE524094D2F05DATA |
ORCH_REQUEST_DEF.BUS_TASK_ID | B81AJF60K28OSD04DATA_entsmfprofileGENERICENTITY.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | CE8DE524094D2F05DATA |
ORCH_REQUEST_DEF.CF_NAME | 1AFCF23B87F15D39DATA |
ORCH_REQUEST_DEF.PROC_STATUS | ACK |
ORCH_QUEUE.CREATE_DATE | 20180911T112542 |
ORCH_QUEUE.UPDATE_DATE | 20180911T112542 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:ent_smf_profile_wrf_generic_load:workflow: ent_smf_profile_wrf_load_entity:event:load_entity:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | -200 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_CE8DE524094D2F05DATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | CE8DE524094D2F05DATA |
User cancels from EJM MT or by dropping RTR with parameters Action=CANCELEVENT, SignalCorrelationId={Incoming file correlation id},CancelChildren=Y, execwkfl gets information about all children files from DB (where ORIG_CORRELATION_ID = SignalCorrelationId) and process cancelation for each one of them consequentially.
ORCH_REQUEST_DEF.BUS_TASK_ID | CE8DE524094D2F05DATA_entsmfprofileGENERICSMF.dat |
ORCH_REQUEST_DEF.SEND_BY | eagle_wrf_generic_load_profile_executor |
ORCH_REQUEST_DEF.CORRELATION_ID | CE8DE524094D2F05DATA |
ORCH_REQUEST_DEF.CF_NAME | 1AFCF23B87F15D39DATA |
ORCH_REQUEST_DEF.PROC_STATUS | ACK |
ORCH_QUEUE.CREATE_DATE | 20180911T112541 |
ORCH_QUEUE.UPDATE_DATE | 20180911T112541 |
ORCH_QUEUE.ORCH_STAT_CLOB | processworkflowname:eagle_wrf_generic_load_profile_executor:workflow::event::triggeredWorkflowCorrId:C92AJI21HCXDCPWD:isBundleTrigger:Y:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat: canceledaschild:Y:cancelcorrelationid:375C79A236048626:ErrorDescr:File processing was canceled. |
ORCH_REQUEST_PARAMS.ORCH_INSTANCE | -418 |
ORCH_REQUEST_PARAMS.PARAMETER_NAME | file_CE8DE524094D2F05DATA |
ORCH_REQUEST_PARAMS.PARAMETER_VALUE | CE8DE524094D2F05DATA |
...
ORCH_REQUEST_DEF.BUS_TASK_ID
...
CE8DE524094D2F05DATA_entsmfprofileGENERICENTITY.dat
...
ORCH_REQUEST_DEF.SEND_BY
...
eagle_wrf_generic_load_profile_executor
...
ORCH_REQUEST_DEF.CORRELATION_ID
...
CE8DE524094D2F05DATA
...
ORCH_REQUEST_DEF.CF_NAME
...
1AFCF23B87F15D39DATA
...
ORCH_REQUEST_DEF.PROC_STATUS
...
ACK
...
ORCH_QUEUE.CREATE_DATE
...
20180911T112542
...
ORCH_QUEUE.UPDATE_DATE
...
20180911T112542
...
ORCH_QUEUE.ORCH_STAT_CLOB
...
processworkflowname:ent_smf_profile_wrf_generic_load:workflow: ent_smf_profile_wrf_load_entity:event:load_entity:genericloadprofile:ent_smf_profile:sourcefilename:profileData.dat:canceledaschild:Y:cancelcorrelationid:375C79A236048626:ErrorDescr:File processing was canceled.
...
ORCH_REQUEST_PARAMS.ORCH_INSTANCE
...
-418
...
ORCH_REQUEST_PARAMS.PARAMETER_NAME
...
file_CE8DE524094D2F05DATA
...
ORCH_REQUEST_PARAMS.PARAMETER_VALUE
...
PossibleScenarios
| Child pages (Children Display) |
|---|