Compile:"Referenced StartLoop cannot be found on input
Posted: Tue Jan 27, 2009 5:06 pm
Hi ETLlers,
I am using StartLoop and EndLoop Activities to do run the job for n times
but while compiling the sequence i am facing this issue
"Referenced StartLoop cannot be found on input link"
Let me know if you coould guess what would be the fix
Don't know who this JobControl will help & is as below:
[* Tokens were replaced below as follows:
* IdV195S6%%UserVar%%0 <= UserVarsE.JobName
* IdV195S6%%UserVar%%1 <= UserVarsE.JobOccrMessage
* IdV0S813%%Result1%%2 <= JobOccStart_0.$ReturnValue
* IdV0S813%%Name%%3 <= JobOccStart_0.$RoutineName
* IdV0S813%%Param%%4 <= JobOccStart_0.aRunStream
* IdV0S813%%Param%%5 <= JobOccStart_0.aRunStreamProcessDate
* IdV0S813%%Param%%6 <= JobOccStart_0.aDatabase
* IdV0S813%%Param%%7 <= JobOccStart_0.aUserid
* IdV0S813%%Param%%8 <= JobOccStart_0.aPassword
* IdV0S813%%Param%%9 <= JobOccStart_0.aValidationJobFlag
* IdV0S926%%Result2%%10 <= PostProcUpdateIB_TRANSACTIONS_1.$UserStatus
* IdV0S926%%Result1%%11 <= PostProcUpdateIB_TRANSACTIONS_1.$JobStatus
* IdV0S926%%Name%%12 <= PostProcUpdateIB_TRANSACTIONS_1.$JobName
* IdV0S936%%Result1%%13 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.$ReturnValue
* IdV0S936%%Name%%14 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.$RoutineName
* IdV0S936%%Param%%15 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aMessageText
* IdV0S936%%Param%%16 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aSeverity
* IdV0S936%%Param%%17 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aDatabase
* IdV0S936%%Param%%18 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aUserid
* IdV0S936%%Param%%19 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aPassword
* IdV0S970%%Result1%%20 <= JobOccrEndOk.$ReturnValue
* IdV0S970%%Name%%21 <= JobOccrEndOk.$RoutineName
* IdV0S970%%Param%%22 <= JobOccrEndOk.aStatus
* IdV0S970%%Param%%23 <= JobOccrEndOk.aRunStream
* IdV0S970%%Param%%24 <= JobOccrEndOk.aRunStreamProcessDate
* IdV0S970%%Param%%25 <= JobOccrEndOk.aCtrlDatabase
* IdV0S970%%Param%%26 <= JobOccrEndOk.aCtrlUserID
* IdV0S970%%Param%%27 <= JobOccrEndOk.aCtrlPassword
* IdV0S970%%Param%%28 <= JobOccrEndOk.aTargetDatabase
* IdV0S970%%Param%%29 <= JobOccrEndOk.aTargetUserID
* IdV0S970%%Param%%30 <= JobOccrEndOk.aTargetPassword
* IdV190S0%%Result1%%31 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.$ReturnValue
* IdV190S0%%Name%%32 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.$RoutineName
* IdV190S0%%Param%%33 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aMessageText
* IdV190S0%%Param%%34 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aSeverity
* IdV190S0%%Param%%35 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aDatabase
* IdV190S0%%Param%%36 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aUserid
* IdV190S0%%Param%%37 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aPassword
* IdV190S1%%Result2%%38 <= PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2.$UserStatus
* IdV190S1%%Result1%%39 <= PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2.$JobStatus
* IdV190S1%%Name%%40 <= PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2.$JobName
* IdV191S0%%Result2%%41 <= PostProcDeleteIB_CASHFLOWS_4.$UserStatus
* IdV191S0%%Result1%%42 <= PostProcDeleteIB_CASHFLOWS_4.$JobStatus
* IdV191S0%%Name%%43 <= PostProcDeleteIB_CASHFLOWS_4.$JobName
* IdV191S3%%Result1%%44 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.$ReturnValue
* IdV191S3%%Name%%45 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.$RoutineName
* IdV191S3%%Param%%46 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aMessageText
* IdV191S3%%Param%%47 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aSeverity
* IdV191S3%%Param%%48 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aDatabase
* IdV191S3%%Param%%49 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aUserid
* IdV191S3%%Param%%50 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aPassword
* IdV191S5%%Result2%%51 <= PostProcUpdateIB_TRANSACTIONS_3.$UserStatus
* IdV191S5%%Result1%%52 <= PostProcUpdateIB_TRANSACTIONS_3.$JobStatus
* IdV191S5%%Name%%53 <= PostProcUpdateIB_TRANSACTIONS_3.$JobName
* IdV192S0%%Result1%%54 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.$ReturnValue
* IdV192S0%%Name%%55 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.$RoutineName
* IdV192S0%%Param%%56 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aMessageText
* IdV192S0%%Param%%57 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aSeverity
* IdV192S0%%Param%%58 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aDatabase
* IdV192S0%%Param%%59 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aUserid
* IdV192S0%%Param%%60 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aPassword
* IdV195S0%%Result1%%61 <= JobOccrMessageException.$ReturnValue
* IdV195S0%%Name%%62 <= JobOccrMessageException.$RoutineName
* IdV195S0%%Param%%63 <= JobOccrMessageException.aMessageText
* IdV195S0%%Param%%64 <= JobOccrMessageException.aSeverity
* IdV195S0%%Param%%65 <= JobOccrMessageException.aDatabase
* IdV195S0%%Param%%66 <= JobOccrMessageException.aUserid
* IdV195S0%%Param%%67 <= JobOccrMessageException.aPassword
* IdV195S1%%Result1%%68 <= JobOccrEndNOK.$ReturnValue
* IdV195S1%%Name%%69 <= JobOccrEndNOK.$RoutineName
* IdV195S1%%Param%%70 <= JobOccrEndNOK.aStatus
* IdV195S1%%Param%%71 <= JobOccrEndNOK.aRunStream
* IdV195S1%%Param%%72 <= JobOccrEndNOK.aRunStreamProcessDate
* IdV195S1%%Param%%73 <= JobOccrEndNOK.aCtrlDatabase
* IdV195S1%%Param%%74 <= JobOccrEndNOK.aCtrlUserID
* IdV195S1%%Param%%75 <= JobOccrEndNOK.aCtrlPassword
* IdV195S1%%Param%%76 <= JobOccrEndNOK.aTargetDatabase
* IdV195S1%%Param%%77 <= JobOccrEndNOK.aTargetUserID
* IdV195S1%%Param%%78 <= JobOccrEndNOK.aTargetPassword
* IdV195S2%%Param%%79 <= ExceptionHandler.$ErrSource
* IdV195S2%%Param%%80 <= ExceptionHandler.$ErrNumber
* IdV195S2%%Param%%81 <= ExceptionHandler.$ErrMessage
*
*** [Generated at 2009-01-16 22:52:41 - 7.5.1.35]
$INCLUDE DSINCLUDE DSJ_XFUNCS.H
EQU Time$$ Lit "Oconv(Time(), 'MTS:'):': '"
****************************************
* Graphical Sequencer generated code for Job SQ50UEPostPMaster
****************************************
seq$V0S913$count = 0
seq$V0S913$status = 0
seq$V0S938$count = 0
seq$V0S938$status = 0
seq$V0S950$count = 0
seq$V0S950$status = 0
seq$V191S4$count = 0
seq$V191S4$status = 0
seq$V0S991$count = 0
seq$V0S991$status = 0
seq$V0S1007$count = 0
seq$V0S1007$status = 0
handle$list = ""
id$list = ""
abort$list = ""
b$Abandoning = @False
b$CPRestarted = @False
b$InErrorRef = @False
rpt$all = ""
summary$restarting = @False
*** Create new checkpoint for sequence if not restarting
If DSCheckPointExists(DSJ.ME, cp$dtm) Then GoTo L$RESTART
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0015\Starting new run of checkpointed Sequence job", ""), "@Coordinator")
If (Not(DSCheckPointValidate(DSJ.ME, cp$msg))) Then
err$source = "@Coordinator"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0016\Error creating checkpoint record<L>%1", cp$msg)
msg$id = "@Coordinator"; GoTo L$ERROR
End
GoTo L$MAINSTART
L$RESTART:
*** Validate restarted job matches prior state
summary$restarting = @True
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0017\Sequence job is being restarted after failure<L>Checkpoint record last modified at %1", cp$dtm), "@Coordinator")
b$CPRestarted = @True
If Not(DSCheckPointValidate(DSJ.ME, cp$msg)) Then
Call DSLogWarn(cp$msg, "@Coordinator")
End
L$MAINSTART:
*** Sequence start point
summary$ = DSMakeMsg("DSTAGE_JSG_M_0048\Summary of sequence run", "")
If summary$restarting Then
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0049\Sequence restarted after failure", ""))
End Else
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0050\Sequence started (checkpointing on)", ""))
End
GoTo L$V0S813$START
L$RETURN$1:
GoTo L$WAITFORJOB
**************************************************
L$V0S813$START:
*** Activity "JobOccStart_0": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccStart_0":@FM:"DSU.JobOccrStart"))
rtn$ok = DSCheckRoutine("DSU.JobOccrStart")
If (Not(rtn$ok)) Then
err$source = "JobOccStart_0"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrStart")
msg$id = "@JobOccStart_0"; GoTo L$ERROR
End
p$V0S813$1 = (pRunStream)
p$V0S813$2 = (pRunStreamProcessDate)
p$V0S813$3 = (pCtrlDatabase)
p$V0S813$4 = (pCtrlUserID)
p$V0S813$5 = (pCtrlPassword)
p$V0S813$6 = "N"
Call 'DSU.JobOccrStart'(r$V0S813, p$V0S813$1, p$V0S813$2, p$V0S813$3, p$V0S813$4, p$V0S813$5, p$V0S813$6)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccStart_0":@FM:r$V0S813))
IdV0S813%%Result1%%2 = r$V0S813
IdV0S813%%Name%%3 = "DSU.JobOccrStart"
IdV0S813%%Param%%4 = (p$V0S813$1)
IdV0S813%%Param%%5 = (p$V0S813$2)
IdV0S813%%Param%%6 = (p$V0S813$3)
IdV0S813%%Param%%7 = (p$V0S813$4)
IdV0S813%%Param%%8 = (p$V0S813$5)
IdV0S813%%Param%%9 = (p$V0S813$6)
If r$V0S813 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrStart":@FM:r$V0S813), "@JobOccStart_0")
End
If (r$V0S813 <> 0) Then
err$source = "JobOccStart_0"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V0S813:@FM:"DSU.JobOccrStart")
msg$id = "@JobOccStart_0"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrStart"), "@JobOccStart_0")
GoSub L$V0S913$START
GoTo L$RETURN$1
**************************************************
L$V0S913$START:
*** Sequencer "SEQ_00": wait until inputs ready
seq$V0S913$status = 1
seq$V0S913$count += 1
If seq$V0S913$count < 1 Then Return
seq$V0S913$status = 2
GoTo L$V0S926$START
L$V0S913$RETURN$1:
Return
**************************************************
L$V0S926$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_1": Initialize job
jb$V0S926 = "UEPostProcUpdateIB_TRANSACTIONS_1"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcUpdateIB_TRANSACTIONS_1":@FM:jb$V0S926))
h$V0S926 = DSAttachJob(jb$V0S926, DSJ.ERRNONE)
If (Not(h$V0S926)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V0S926:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
h$V0S926 = DSPrepareJob(h$V0S926)
If (Not(h$V0S926)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V0S926:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
L$V0S926$PREPARED:
p$V0S926$1 = (pRunStream)
err$code = DSSetParam(h$V0S926, "pRunStream", p$V0S926$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V0S926, "pTempProcessFilePath", p$V0S926$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$3 = (pRerunFlag)
err$code = DSSetParam(h$V0S926, "pRerunFlag", p$V0S926$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$4 = (pTargetUserID)
err$code = DSSetParam(h$V0S926, "pTargetUserID", p$V0S926$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$5 = (pTargetPassword)
err$code = DSSetParam(h$V0S926, "pTargetPassword", p$V0S926$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$6 = (pTargetDatabase)
err$code = DSSetParam(h$V0S926, "pTargetDatabase", p$V0S926$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
err$code = DSRunJob(h$V0S926, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V0S926:@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
handle$list<-1> = h$V0S926
id$list<-1> = "V0S926"
GoTo L$V0S913$RETURN$1
**************************************************
L$V0S926$FINISHED:
job$V0S926$status = DSGetJobInfo(h$V0S926, DSJ.JOBSTATUS)
job$V0S926$userstatus = DSGetJobInfo(h$V0S926, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcUpdateIB_TRANSACTIONS_1":@FM:jb$V0S926:@FM:job$V0S926$status))
IdV0S926%%Result2%%10 = job$V0S926$userstatus
IdV0S926%%Result1%%11 = job$V0S926$status
IdV0S926%%Name%%12 = jb$V0S926
If (job$V0S926$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V0S926:@FM:DSTranslateCode(job$V0S926$status)), "@PostProcUpdateIB_TRANSACTIONS_1")
End
rpt$V0S926 = DSMakeJobReport(h$V0S926, 1, "CRLF")
rpt$all := "\n":rpt$V0S926 ;* accumulate job reports
dummy$ = DSDetachJob(h$V0S926)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V0S926), "@PostProcUpdateIB_TRANSACTIONS_1")
If b$Abandoning Then GoTo L$WAITFORJOB
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V0S938$START
If (job$V0S926$status <> DSJS.RUNOK And job$V0S926$status <> DSJS.RUNWARN) Then GoTo L$V0S936$START
L$V0S926$RETURN$2:
GoTo L$WAITFORJOB
**************************************************
L$V0S936$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_1_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_1_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1_Failed"; GoTo L$ERROR
End
p$V0S936$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V0S936$2 = "A"
p$V0S936$3 = (pCtrlDatabase)
p$V0S936$4 = (pCtrlUserID)
p$V0S936$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V0S936, p$V0S936$1, p$V0S936$2, p$V0S936$3, p$V0S936$4, p$V0S936$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_1_Failed":@FM:r$V0S936))
IdV0S936%%Result1%%13 = r$V0S936
IdV0S936%%Name%%14 = "DSU.JobOccrMessage"
IdV0S936%%Param%%15 = (p$V0S936$1)
IdV0S936%%Param%%16 = (p$V0S936$2)
IdV0S936%%Param%%17 = (p$V0S936$3)
IdV0S936%%Param%%18 = (p$V0S936$4)
IdV0S936%%Param%%19 = (p$V0S936$5)
If r$V0S936 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V0S936), "@PostProcUpdateIB_TRANSACTIONS_1_Failed")
End
If (r$V0S936 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V0S936:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_1_Failed")
GoTo L$V0S926$RETURN$2
**************************************************
L$V0S938$START:
*** Sequencer "SEQ_01a": wait until inputs ready
seq$V0S938$status = 1
If seq$V0S938$count > 0 Then Return
seq$V0S938$count += 1
seq$V0S938$status = 2
GoTo L$V190S1$START
L$V0S938$RETURN$1:
Return
**************************************************
L$V0S950$START:
*** Sequencer "SEQ_End": wait until inputs ready
seq$V0S950$status = 1
seq$V0S950$count += 1
If seq$V0S950$count < 1 Then Return
seq$V0S950$status = 2
GoTo L$V0S970$START
L$V0S950$RETURN$1:
Return
**************************************************
L$V0S970$START:
*** Activity "JobOccrEndOk": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccrEndOk":@FM:"DSU.JobOccrEnd"))
rtn$ok = DSCheckRoutine("DSU.JobOccrEnd")
If (Not(rtn$ok)) Then
err$source = "JobOccrEndOk"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrEnd")
msg$id = "@JobOccrEndOk"; GoTo L$ERROR
End
p$V0S970$1 = "C"
p$V0S970$2 = (pRunStream)
p$V0S970$3 = (pRunStreamProcessDate)
p$V0S970$4 = (pCtrlDatabase)
p$V0S970$5 = (pCtrlUserID)
p$V0S970$6 = (pCtrlPassword)
p$V0S970$7 = (pTargetDatabase)
p$V0S970$8 = (pTargetUserID)
p$V0S970$9 = (pTargetPassword)
Call 'DSU.JobOccrEnd'(r$V0S970, p$V0S970$1, p$V0S970$2, p$V0S970$3, p$V0S970$4, p$V0S970$5, p$V0S970$6, p$V0S970$7, p$V0S970$8, p$V0S970$9)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccrEndOk":@FM:r$V0S970))
IdV0S970%%Result1%%20 = r$V0S970
IdV0S970%%Name%%21 = "DSU.JobOccrEnd"
IdV0S970%%Param%%22 = (p$V0S970$1)
IdV0S970%%Param%%23 = (p$V0S970$2)
IdV0S970%%Param%%24 = (p$V0S970$3)
IdV0S970%%Param%%25 = (p$V0S970$4)
IdV0S970%%Param%%26 = (p$V0S970$5)
IdV0S970%%Param%%27 = (p$V0S970$6)
IdV0S970%%Param%%28 = (p$V0S970$7)
IdV0S970%%Param%%29 = (p$V0S970$8)
IdV0S970%%Param%%30 = (p$V0S970$9)
If r$V0S970 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrEnd":@FM:r$V0S970), "@JobOccrEndOk")
End
If (r$V0S970 <> 0) Then
err$source = "JobOccrEndOk"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V0S970:@FM:"DSU.JobOccrEnd")
msg$id = "@JobOccrEndOk"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrEnd"), "@JobOccrEndOk")
GoTo L$V0S950$RETURN$1
**************************************************
L$V190S0$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_2_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_2_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_2_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_2_Failed"; GoTo L$ERROR
End
p$V190S0$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V190S0$2 = "A"
p$V190S0$3 = (pCtrlDatabase)
p$V190S0$4 = (pCtrlUserID)
p$V190S0$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V190S0, p$V190S0$1, p$V190S0$2, p$V190S0$3, p$V190S0$4, p$V190S0$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_2_Failed":@FM:r$V190S0))
IdV190S0%%Result1%%31 = r$V190S0
IdV190S0%%Name%%32 = "DSU.JobOccrMessage"
IdV190S0%%Param%%33 = (p$V190S0$1)
IdV190S0%%Param%%34 = (p$V190S0$2)
IdV190S0%%Param%%35 = (p$V190S0$3)
IdV190S0%%Param%%36 = (p$V190S0$4)
IdV190S0%%Param%%37 = (p$V190S0$5)
If r$V190S0 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V190S0), "@PostProcUpdateIB_TRANSACTIONS_2_Failed")
End
If (r$V190S0 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_2_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V190S0:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_2_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_2_Failed")
GoTo L$V190S1$RETURN$2
**************************************************
L$V190S1$START:
*** Activity "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2": Initialize job
jb$V190S1 = "UEPostProcUpdateIB_SWAP_TRANS_LEGS_2"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2":@FM:jb$V190S1))
h$V190S1 = DSAttachJob(jb$V190S1, DSJ.ERRNONE)
If (Not(h$V190S1)) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V190S1:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
h$V190S1 = DSPrepareJob(h$V190S1)
If (Not(h$V190S1)) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V190S1:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
L$V190S1$PREPARED:
p$V190S1$1 = (pRunStream)
err$code = DSSetParam(h$V190S1, "pRunStream", p$V190S1$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V190S1, "pTempProcessFilePath", p$V190S1$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$3 = (pRerunFlag)
err$code = DSSetParam(h$V190S1, "pRerunFlag", p$V190S1$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$4 = (pTargetUserID)
err$code = DSSetParam(h$V190S1, "pTargetUserID", p$V190S1$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$5 = (pTargetPassword)
err$code = DSSetParam(h$V190S1, "pTargetPassword", p$V190S1$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$6 = (pTargetDatabase)
err$code = DSSetParam(h$V190S1, "pTargetDatabase", p$V190S1$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
err$code = DSRunJob(h$V190S1, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V190S1:@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
handle$list<-1> = h$V190S1
id$list<-1> = "V190S1"
GoTo L$V0S938$RETURN$1
**************************************************
L$V190S1$FINISHED:
job$V190S1$status = DSGetJobInfo(h$V190S1, DSJ.JOBSTATUS)
job$V190S1$userstatus = DSGetJobInfo(h$V190S1, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2":@FM:jb$V190S1:@FM:job$V190S1$status))
IdV190S1%%Result2%%38 = job$V190S1$userstatus
IdV190S1%%Result1%%39 = job$V190S1$status
IdV190S1%%Name%%40 = jb$V190S1
If (job$V190S1$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V190S1:@FM:DSTranslateCode(job$V190S1$status)), "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2")
End
rpt$V190S1 = DSMakeJobReport(h$V190S1, 1, "CRLF")
rpt$all := "\n":rpt$V190S1 ;* accumulate job reports
dummy$ = DSDetachJob(h$V190S1)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V190S1), "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2")
If b$Abandoning Then GoTo L$WAITFORJOB
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V0S991$START
If (job$V190S1$status <> DSJS.RUNOK And job$V190S1$status <> DSJS.RUNWARN) Then GoTo L$V190S0$START
L$V190S1$RETURN$2:
GoTo L$WAITFORJOB
**************************************************
L$V191S0$START:
*** Activity "PostProcDeleteIB_CASHFLOWS_4": Initialize job
jb$V191S0 = "UEPostProcDeleteIB_CASHFLOWS_4"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcDeleteIB_CASHFLOWS_4":@FM:jb$V191S0))
h$V191S0 = DSAttachJob(jb$V191S0, DSJ.ERRNONE)
If (Not(h$V191S0)) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V191S0:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
h$V191S0 = DSPrepareJob(h$V191S0)
If (Not(h$V191S0)) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V191S0:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
L$V191S0$PREPARED:
p$V191S0$1 = (pRunStream)
err$code = DSSetParam(h$V191S0, "pRunStream", p$V191S0$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V191S0, "pTempProcessFilePath", p$V191S0$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$3 = (pRerunFlag)
err$code = DSSetParam(h$V191S0, "pRerunFlag", p$V191S0$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$4 = (pTargetUserID)
err$code = DSSetParam(h$V191S0, "pTargetUserID", p$V191S0$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$5 = (pTargetPassword)
err$code = DSSetParam(h$V191S0, "pTargetPassword", p$V191S0$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$6 = (pTargetDatabase)
err$code = DSSetParam(h$V191S0, "pTargetDatabase", p$V191S0$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
err$code = DSRunJob(h$V191S0, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V191S0:@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
handle$list<-1> = h$V191S0
id$list<-1> = "V191S0"
GoTo L$V191S4$RETURN$1
**************************************************
L$V191S0$FINISHED:
job$V191S0$status = DSGetJobInfo(h$V191S0, DSJ.JOBSTATUS)
job$V191S0$userstatus = DSGetJobInfo(h$V191S0, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcDeleteIB_CASHFLOWS_4":@FM:jb$V191S0:@FM:job$V191S0$status))
IdV191S0%%Result2%%41 = job$V191S0$userstatus
IdV191S0%%Result1%%42 = job$V191S0$status
IdV191S0%%Name%%43 = jb$V191S0
If (job$V191S0$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V191S0:@FM:DSTranslateCode(job$V191S0$status)), "@PostProcDeleteIB_CASHFLOWS_4")
End
rpt$V191S0 = DSMakeJobReport(h$V191S0, 1, "CRLF")
rpt$all := "\n":rpt$V191S0 ;* accumulate job reports
dummy$ = DSDetachJob(h$V191S0)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V191S0), "@PostProcDeleteIB_CASHFLOWS_4")
If b$Abandoning Then GoTo L$WAITFORJOB
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V0S1007$START
If (job$V191S0$status <> DSJS.RUNOK And job$V191S0$status <> DSJS.RUNWARN) Then GoTo L$V191S3$START
L$V191S0$RETURN$2:
GoTo L$WAITFORJOB
**************************************************
L$V191S3$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_4_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_4_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_4_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_4_Failed"; GoTo L$ERROR
End
p$V191S3$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V191S3$2 = "A"
p$V191S3$3 = (pCtrlDatabase)
p$V191S3$4 = (pCtrlUserID)
p$V191S3$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V191S3, p$V191S3$1, p$V191S3$2, p$V191S3$3, p$V191S3$4, p$V191S3$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_4_Failed":@FM:r$V191S3))
IdV191S3%%Result1%%44 = r$V191S3
IdV191S3%%Name%%45 = "DSU.JobOccrMessage"
IdV191S3%%Param%%46 = (p$V191S3$1)
IdV191S3%%Param%%47 = (p$V191S3$2)
IdV191S3%%Param%%48 = (p$V191S3$3)
IdV191S3%%Param%%49 = (p$V191S3$4)
IdV191S3%%Param%%50 = (p$V191S3$5)
If r$V191S3 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V191S3), "@PostProcUpdateIB_TRANSACTIONS_4_Failed")
End
If (r$V191S3 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_4_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V191S3:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_4_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_4_Failed")
GoTo L$V191S0$RETURN$2
**************************************************
L$V191S4$START:
*** Sequencer "SEQ_03a": wait until inputs ready
seq$V191S4$status = 1
If seq$V191S4$count > 0 Then Return
seq$V191S4$count += 1
seq$V191S4$status = 2
GoTo L$V191S0$START
L$V191S4$RETURN$1:
Return
**************************************************
L$V191S5$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_3": Initialize job
jb$V191S5 = "UEPostProcUpdateIB_TRANSACTIONS_3"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcUpdateIB_TRANSACTIONS_3":@FM:jb$V191S5))
h$V191S5 = DSAttachJob(jb$V191S5, DSJ.ERRNONE)
If (Not(h$V191S5)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V191S5:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
h$V191S5 = DSPrepareJob(h$V191S5)
If (Not(h$V191S5)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V191S5:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
L$V191S5$PREPARED:
p$V191S5$1 = (pRunStream)
err$code = DSSetParam(h$V191S5, "pRunStream", p$V191S5$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V191S5, "pTempProcessFilePath", p$V191S5$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$3 = (pRerunFlag)
err$code = DSSetParam(h$V191S5, "pRerunFlag", p$V191S5$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$4 = (pTargetUserID)
err$code = DSSetParam(h$V191S5, "pTargetUserID", p$V191S5$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$5 = (pTargetPassword)
err$code = DSSetParam(h$V191S5, "pTargetPassword", p$V191S5$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$6 = (pTargetDatabase)
err$code = DSSetParam(h$V191S5, "pTargetDatabase", p$V191S5$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
err$code = DSRunJob(h$V191S5, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V191S5:@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
handle$list<-1> = h$V191S5
id$list<-1> = "V191S5"
GoTo L$V0S991$RETURN$1
**************************************************
L$V191S5$FINISHED:
job$V191S5$status = DSGetJobInfo(h$V191S5, DSJ.JOBSTATUS)
job$V191S5$userstatus = DSGetJobInfo(h$V191S5, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcUpdateIB_TRANSACTIONS_3":@FM:jb$V191S5:@FM:job$V191S5$status))
IdV191S5%%Result2%%51 = job$V191S5$userstatus
IdV191S5%%Result1%%52 = job$V191S5$status
IdV191S5%%Name%%53 = jb$V191S5
If (job$V191S5$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V191S5:@FM:DSTranslateCode(job$V191S5$status)), "@PostProcUpdateIB_TRANSACTIONS_3")
End
rpt$V191S5 = DSMakeJobReport(h$V191S5, 1, "CRLF")
rpt$all := "\n":rpt$V191S5 ;* accumulate job reports
dummy$ = DSDetachJob(h$V191S5)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V191S5), "@PostProcUpdateIB_TRANSACTIONS_3")
If b$Abandoning Then GoTo L$WAITFORJOB
If (job$V191S5$status <> DSJS.RUNOK And job$V191S5$status <> DSJS.RUNWARN) Then GoTo L$V192S0$START
L$V191S5$RETURN$1:
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V191S4$START
GoTo L$WAITFORJOB
**************************************************
L$V0S991$START:
*** Sequencer "SEQ_02a": wait until inputs ready
seq$V0S991$status = 1
If seq$V0S991$count > 0 Then Return
seq$V0S991$count += 1
seq$V0S991$status = 2
GoTo L$V191S5$START
L$V0S991$RETURN$1:
Return
**************************************************
L$V192S0$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_3_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_3_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3_Failed"; GoTo L$ERROR
End
p$V192S0$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V192S0$2 = "A"
p$V192S0$3 = (pCtrlDatabase)
p$V192S0$4 = (pCtrlUserID)
p$V192S0$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V192S0, p$V192S0$1, p$V192S0$2, p$V192S0$3, p$V192S0$4, p$V192S0$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_3_Failed":@FM:r$V192S0))
IdV192S0%%Result1%%54 = r$V192S0
IdV192S0%%Name%%55 = "DSU.JobOccrMessage"
IdV192S0%%Param%%56 = (p$V192S0$1)
IdV192S0%%Param%%57 = (p$V192S0$2)
IdV192S0%%Param%%58 = (p$V192S0$3)
IdV192S0%%Param%%59 = (p$V192S0$4)
IdV192S0%%Param%%60 = (p$V192S0$5)
If r$V192S0 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V192S0), "@PostProcUpdateIB_TRANSACTIONS_3_Failed")
End
If (r$V192S0 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V192S0:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_3_Failed")
GoTo L$V191S5$RETURN$1
**************************************************
L$V0S1007$START:
*** Sequencer "SEQ_04a": wait until inputs ready
seq$V0S1007$status = 1
If seq$V0S1007$count > 0 Then Return
seq$V0S1007$count += 1
seq$V0S1007$status = 2
GoSub L$V0S950$START
Return
**************************************************
L$V195S0$START:
*** Activity "JobOccrMessageException": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccrMessageException":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "JobOccrMessageException"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@JobOccrMessageException"; GoTo L$ERROR
End
p$V195S0$1 = (IdV195S6%%UserVar%%1)
p$V195S0$2 = ('I')
p$V195S0$3 = (pCtrlDatabase)
p$V195S0$4 = (pCtrlUserID)
p$V195S0$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V195S0, p$V195S0$1, p$V195S0$2, p$V195S0$3, p$V195S0$4, p$V195S0$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccrMessageException":@FM:r$V195S0))
IdV195S0%%Result1%%61 = r$V195S0
IdV195S0%%Name%%62 = "DSU.JobOccrMessage"
IdV195S0%%Param%%63 = (p$V195S0$1)
IdV195S0%%Param%%64 = (p$V195S0$2)
IdV195S0%%Param%%65 = (p$V195S0$3)
IdV195S0%%Param%%66 = (p$V195S0$4)
IdV195S0%%Param%%67 = (p$V195S0$5)
If r$V195S0 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V195S0), "@JobOccrMessageException")
End
If (r$V195S0 <> 0) Then
err$source = "JobOccrMessageException"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V195S0:@FM:"DSU.JobOccrMessage")
msg$id = "@JobOccrMessageException"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@JobOccrMessageException")
GoTo L$V195S5$START
L$V195S0$RETURN$1:
GoTo L$V195S6$RETURN$1
**************************************************
L$V195S1$START:
*** Activity "JobOccrEndNOK": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccrEndNOK":@FM:"DSU.JobOccrEnd"))
rtn$ok = DSCheckRoutine("DSU.JobOccrEnd")
If (Not(rtn$ok)) Then
err$source = "JobOccrEndNOK"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrEnd")
msg$id = "@JobOccrEndNOK"; GoTo L$ERROR
End
p$V195S1$1 = ('A')
p$V195S1$2 = (pRunStream)
p$V195S1$3 = (pRunStreamProcessDate)
p$V195S1$4 = (pCtrlDatabase)
p$V195S1$5 = (pCtrlUserID)
p$V195S1$6 = (pCtrlPassword)
p$V195S1$7 = (pTargetDatabase)
p$V195S1$8 = (pTargetUserID)
p$V195S1$9 = (pTargetPassword)
Call 'DSU.JobOccrEnd'(r$V195S1, p$V195S1$1, p$V195S1$2, p$V195S1$3, p$V195S1$4, p$V195S1$5, p$V195S1$6, p$V195S1$7, p$V195S1$8, p$V195S1$9)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccrEndNOK":@FM:r$V195S1))
IdV195S1%%Result1%%68 = r$V195S1
IdV195S1%%Name%%69 = "DSU.JobOccrEnd"
IdV195S1%%Param%%70 = (p$V195S1$1)
IdV195S1%%Param%%71 = (p$V195S1$2)
IdV195S1%%Param%%72 = (p$V195S1$3)
IdV195S1%%Param%%73 = (p$V195S1$4)
IdV195S1%%Param%%74 = (p$V195S1$5)
IdV195S1%%Param%%75 = (p$V195S1$6)
IdV195S1%%Param%%76 = (p$V195S1$7)
IdV195S1%%Param%%77 = (p$V195S1$8)
IdV195S1%%Param%%78 = (p$V195S1$9)
If r$V195S1 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrEnd":@FM:r$V195S1), "@JobOccrEndNOK")
End
If (r$V195S1 <> 0) Then
err$source = "JobOccrEndNOK"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V195S1:@FM:"DSU.JobOccrEnd")
msg$id = "@JobOccrEndNOK"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrEnd"), "@JobOccrEndNOK")
GoTo L$V195S6$START
L$V195S1$RETURN$1:
GoTo L$V195S2$RETURN$1
**************************************************
L$V195S2$START:
*** Decision "ExceptionHandler"
GoTo L$V195S1$START
L$V195S2$RETURN$1:
GoTo L$WAITFORJOB
**************************************************
L$V195S3$START:
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0065\%1 Executed", "Terminate"))
* Send stop request to any outstanding child jobs
For index$ = 1 To DCount(handle$list, @FM)
handle$ = handle$list<index$>
If handle$ <> "" Then
job$name = DSGetJobInfo(handle$, DSJ.JOBNAME)
job$invid = DSGetJobInfo(handle$, DSJ.JOBINVOCATIONID)
if job$invid <> "" Then job$name = job$name:".":job$invid
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0019\Sending STOP request to job: %1", job$name), "@Terminate")
dummy$ = DSStopJob(handle$)
End
Next index$
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0069\Sequence terminated", ""))
Call DSLogInfo(summary$, "@Coordinator")
Call DSLogFatal(DSMakeMsg("DSTAGE_JSG_M_0020\Sequence abort requested", ""), "@Terminate")
**************************************************
L$V195S5$START:
*** Activity "Notify": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "Notify":@FM:"DSSendMail"))
rtn$ok = DSCheckRoutine("DSSendMail")
If (Not(rtn$ok)) Then
err$source = "Notify"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSSendMail")
msg$id = "@Notify"; GoTo L$ERROR
End
p$V195S5$0 = "To:":pRecipientMailAddress:"\nFrom:":pSenderMailAddress:"\nSubject:DataStage job ":IdV195S6%%UserVar%%0:" has failed in activity ":IdV195S2%%Param%%79:".\nServer:":pSMTPServer:"\nBody:This is an automatically generated email from DataStage. Do not reply.\n":rpt$all
Call 'DSSendMail'(r$V195S5, p$V195S5$0)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "Notify":@FM:r$V195S5))
If r$V195S5 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSSendMail":@FM:r$V195S5), "@Notify")
End
If (r$V195S5 <> 0) Then
err$source = "Notify"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V195S5:@FM:"DSSendMail")
msg$id = "@Notify"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSSendMail"), "@Notify")
GoTo L$V195S3$START
L$V195S5$RETURN$1:
GoTo L$V195S0$RETURN$1
**************************************************
L$V195S6$START:
*** Set user variables: "UserVarsE"
IdV195S6%%UserVar%%0 = (DSJobName : ( If Len(DSJobInvocationId) > 1 then "." else "") : DSJobInvocationId)
IdV195S6%%UserVar%%1 = ('DataStage job has failed in activity ' : IdV195S2%%Param%%79 : '.')
GoTo L$V195S0$START
L$V195S6$RETURN$1:
GoTo L$V195S1$RETURN$1
**************************************************
L$WAITFORJOB:
If handle$list = "" Then GoTo L$FINISH
handle$ = DSWaitForJob(handle$list)
If handle$ = 0 Then handle$ = handle$list<1>
Locate handle$ In handle$list Setting index$ Then
id$ = id$list<index$>
Del id$list<index$>; Del handle$list<index$>
b$Abandoning = abort$list<index$>; Del abort$list<index$>
Begin Case
Case id$ = "V0S926"
GoTo L$V0S926$FINISHED
Case id$ = "V190S1"
GoTo L$V190S1$FINISHED
Case id$ = "V191S0"
GoTo L$V191S0$FINISHED
Case id$ = "V191S5"
GoTo L$V191S5$FINISHED
End Case
End
* Error if fall though
handle$list = ""
err$source = "@Coordinator"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0008\Error calling DSWaitForJob(), code=%1[E]", handle$)
msg$id = "@Coordinator"; GoTo L$ERROR
**************************************************
L$ERROR:
IdV195S2%%Param%%79 = err$source
IdV195S2%%Param%%80 = err$number
IdV195S2%%Param%%81 = msg$
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0009\Controller problem: %1", msg$), msg$id)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0052\Exception raised: %1", msg$id:", ":msg$))
If Not(b$InErrorRef) Then
dummy$ = DSCheckPointSetValue(DSJ.ME, "!", DSMakeMsg("DSTAGE_JSG_M_0031\Failed at: %1, Reason=%2", err$source:@FM:msg$))
End
abort$list = Ifs(handle$list, Str(1:@FM, DCount(handle$list, @FM)), "")
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0053\Exception handler started", ""))
If Not(b$InErrorRef) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0010\Will execute error activity: %1", "ExceptionHandler"), msg$id)
b$InErrorRef = @True
b$NumStarted = 1
GoTo L$V195S2$START
End Else
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0011\Error while executing error activity: %1", "ExceptionHandler"), msg$id)
End
b$Abandoning = @True
GoTo L$WAITFORJOB
L$ABORT:
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0055\Sequence failed (restartable)", ""))
Call DSLogInfo(summary$, "@Coordinator")
Call DSLogFatal(DSMakeMsg("DSTAGE_JSG_M_0014\Sequence job (restartable) will abort due to previous unrecoverable errors", ""), "@Coordinator")
**************************************************
L$FINISH:
If b$Abandoning Then GoTo L$ABORT
*** At successful exit remove checkpoint record
If Not(b$InErrorRef) And DSCheckPointExists(DSJ.ME, cp$dtm) Then
dummy$ = DSCheckPointDelete(DSJ.ME)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0018\Removed checkpoint record at successful completion of sequence", ""), "@Coordinator")
End
If (seq$V0S913$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_00"), "@Coordinator")
End
If (seq$V0S938$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_01a"), "@Coordinator")
End
If (seq$V0S950$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_End"), "@Coordinator")
End
If (seq$V191S4$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_03a"), "@Coordinator")
End
If (seq$V0S991$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_02a"), "@Coordinator")
End
If (seq$V0S1007$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_04a"), "@Coordinator")
End
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0054\Sequence finished OK", ""))
Call DSLogInfo(summary$, "@Coordinator")
L$EXIT: Return To L$EXIT
][/code]
I am using StartLoop and EndLoop Activities to do run the job for n times
but while compiling the sequence i am facing this issue
"Referenced StartLoop cannot be found on input link"
Let me know if you coould guess what would be the fix
Don't know who this JobControl will help & is as below:
[* Tokens were replaced below as follows:
* IdV195S6%%UserVar%%0 <= UserVarsE.JobName
* IdV195S6%%UserVar%%1 <= UserVarsE.JobOccrMessage
* IdV0S813%%Result1%%2 <= JobOccStart_0.$ReturnValue
* IdV0S813%%Name%%3 <= JobOccStart_0.$RoutineName
* IdV0S813%%Param%%4 <= JobOccStart_0.aRunStream
* IdV0S813%%Param%%5 <= JobOccStart_0.aRunStreamProcessDate
* IdV0S813%%Param%%6 <= JobOccStart_0.aDatabase
* IdV0S813%%Param%%7 <= JobOccStart_0.aUserid
* IdV0S813%%Param%%8 <= JobOccStart_0.aPassword
* IdV0S813%%Param%%9 <= JobOccStart_0.aValidationJobFlag
* IdV0S926%%Result2%%10 <= PostProcUpdateIB_TRANSACTIONS_1.$UserStatus
* IdV0S926%%Result1%%11 <= PostProcUpdateIB_TRANSACTIONS_1.$JobStatus
* IdV0S926%%Name%%12 <= PostProcUpdateIB_TRANSACTIONS_1.$JobName
* IdV0S936%%Result1%%13 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.$ReturnValue
* IdV0S936%%Name%%14 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.$RoutineName
* IdV0S936%%Param%%15 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aMessageText
* IdV0S936%%Param%%16 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aSeverity
* IdV0S936%%Param%%17 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aDatabase
* IdV0S936%%Param%%18 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aUserid
* IdV0S936%%Param%%19 <= PostProcUpdateIB_TRANSACTIONS_1_Failed.aPassword
* IdV0S970%%Result1%%20 <= JobOccrEndOk.$ReturnValue
* IdV0S970%%Name%%21 <= JobOccrEndOk.$RoutineName
* IdV0S970%%Param%%22 <= JobOccrEndOk.aStatus
* IdV0S970%%Param%%23 <= JobOccrEndOk.aRunStream
* IdV0S970%%Param%%24 <= JobOccrEndOk.aRunStreamProcessDate
* IdV0S970%%Param%%25 <= JobOccrEndOk.aCtrlDatabase
* IdV0S970%%Param%%26 <= JobOccrEndOk.aCtrlUserID
* IdV0S970%%Param%%27 <= JobOccrEndOk.aCtrlPassword
* IdV0S970%%Param%%28 <= JobOccrEndOk.aTargetDatabase
* IdV0S970%%Param%%29 <= JobOccrEndOk.aTargetUserID
* IdV0S970%%Param%%30 <= JobOccrEndOk.aTargetPassword
* IdV190S0%%Result1%%31 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.$ReturnValue
* IdV190S0%%Name%%32 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.$RoutineName
* IdV190S0%%Param%%33 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aMessageText
* IdV190S0%%Param%%34 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aSeverity
* IdV190S0%%Param%%35 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aDatabase
* IdV190S0%%Param%%36 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aUserid
* IdV190S0%%Param%%37 <= PostProcUpdateIB_TRANSACTIONS_2_Failed.aPassword
* IdV190S1%%Result2%%38 <= PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2.$UserStatus
* IdV190S1%%Result1%%39 <= PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2.$JobStatus
* IdV190S1%%Name%%40 <= PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2.$JobName
* IdV191S0%%Result2%%41 <= PostProcDeleteIB_CASHFLOWS_4.$UserStatus
* IdV191S0%%Result1%%42 <= PostProcDeleteIB_CASHFLOWS_4.$JobStatus
* IdV191S0%%Name%%43 <= PostProcDeleteIB_CASHFLOWS_4.$JobName
* IdV191S3%%Result1%%44 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.$ReturnValue
* IdV191S3%%Name%%45 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.$RoutineName
* IdV191S3%%Param%%46 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aMessageText
* IdV191S3%%Param%%47 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aSeverity
* IdV191S3%%Param%%48 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aDatabase
* IdV191S3%%Param%%49 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aUserid
* IdV191S3%%Param%%50 <= PostProcUpdateIB_TRANSACTIONS_4_Failed.aPassword
* IdV191S5%%Result2%%51 <= PostProcUpdateIB_TRANSACTIONS_3.$UserStatus
* IdV191S5%%Result1%%52 <= PostProcUpdateIB_TRANSACTIONS_3.$JobStatus
* IdV191S5%%Name%%53 <= PostProcUpdateIB_TRANSACTIONS_3.$JobName
* IdV192S0%%Result1%%54 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.$ReturnValue
* IdV192S0%%Name%%55 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.$RoutineName
* IdV192S0%%Param%%56 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aMessageText
* IdV192S0%%Param%%57 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aSeverity
* IdV192S0%%Param%%58 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aDatabase
* IdV192S0%%Param%%59 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aUserid
* IdV192S0%%Param%%60 <= PostProcUpdateIB_TRANSACTIONS_3_Failed.aPassword
* IdV195S0%%Result1%%61 <= JobOccrMessageException.$ReturnValue
* IdV195S0%%Name%%62 <= JobOccrMessageException.$RoutineName
* IdV195S0%%Param%%63 <= JobOccrMessageException.aMessageText
* IdV195S0%%Param%%64 <= JobOccrMessageException.aSeverity
* IdV195S0%%Param%%65 <= JobOccrMessageException.aDatabase
* IdV195S0%%Param%%66 <= JobOccrMessageException.aUserid
* IdV195S0%%Param%%67 <= JobOccrMessageException.aPassword
* IdV195S1%%Result1%%68 <= JobOccrEndNOK.$ReturnValue
* IdV195S1%%Name%%69 <= JobOccrEndNOK.$RoutineName
* IdV195S1%%Param%%70 <= JobOccrEndNOK.aStatus
* IdV195S1%%Param%%71 <= JobOccrEndNOK.aRunStream
* IdV195S1%%Param%%72 <= JobOccrEndNOK.aRunStreamProcessDate
* IdV195S1%%Param%%73 <= JobOccrEndNOK.aCtrlDatabase
* IdV195S1%%Param%%74 <= JobOccrEndNOK.aCtrlUserID
* IdV195S1%%Param%%75 <= JobOccrEndNOK.aCtrlPassword
* IdV195S1%%Param%%76 <= JobOccrEndNOK.aTargetDatabase
* IdV195S1%%Param%%77 <= JobOccrEndNOK.aTargetUserID
* IdV195S1%%Param%%78 <= JobOccrEndNOK.aTargetPassword
* IdV195S2%%Param%%79 <= ExceptionHandler.$ErrSource
* IdV195S2%%Param%%80 <= ExceptionHandler.$ErrNumber
* IdV195S2%%Param%%81 <= ExceptionHandler.$ErrMessage
*
*** [Generated at 2009-01-16 22:52:41 - 7.5.1.35]
$INCLUDE DSINCLUDE DSJ_XFUNCS.H
EQU Time$$ Lit "Oconv(Time(), 'MTS:'):': '"
****************************************
* Graphical Sequencer generated code for Job SQ50UEPostPMaster
****************************************
seq$V0S913$count = 0
seq$V0S913$status = 0
seq$V0S938$count = 0
seq$V0S938$status = 0
seq$V0S950$count = 0
seq$V0S950$status = 0
seq$V191S4$count = 0
seq$V191S4$status = 0
seq$V0S991$count = 0
seq$V0S991$status = 0
seq$V0S1007$count = 0
seq$V0S1007$status = 0
handle$list = ""
id$list = ""
abort$list = ""
b$Abandoning = @False
b$CPRestarted = @False
b$InErrorRef = @False
rpt$all = ""
summary$restarting = @False
*** Create new checkpoint for sequence if not restarting
If DSCheckPointExists(DSJ.ME, cp$dtm) Then GoTo L$RESTART
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0015\Starting new run of checkpointed Sequence job", ""), "@Coordinator")
If (Not(DSCheckPointValidate(DSJ.ME, cp$msg))) Then
err$source = "@Coordinator"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0016\Error creating checkpoint record<L>%1", cp$msg)
msg$id = "@Coordinator"; GoTo L$ERROR
End
GoTo L$MAINSTART
L$RESTART:
*** Validate restarted job matches prior state
summary$restarting = @True
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0017\Sequence job is being restarted after failure<L>Checkpoint record last modified at %1", cp$dtm), "@Coordinator")
b$CPRestarted = @True
If Not(DSCheckPointValidate(DSJ.ME, cp$msg)) Then
Call DSLogWarn(cp$msg, "@Coordinator")
End
L$MAINSTART:
*** Sequence start point
summary$ = DSMakeMsg("DSTAGE_JSG_M_0048\Summary of sequence run", "")
If summary$restarting Then
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0049\Sequence restarted after failure", ""))
End Else
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0050\Sequence started (checkpointing on)", ""))
End
GoTo L$V0S813$START
L$RETURN$1:
GoTo L$WAITFORJOB
**************************************************
L$V0S813$START:
*** Activity "JobOccStart_0": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccStart_0":@FM:"DSU.JobOccrStart"))
rtn$ok = DSCheckRoutine("DSU.JobOccrStart")
If (Not(rtn$ok)) Then
err$source = "JobOccStart_0"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrStart")
msg$id = "@JobOccStart_0"; GoTo L$ERROR
End
p$V0S813$1 = (pRunStream)
p$V0S813$2 = (pRunStreamProcessDate)
p$V0S813$3 = (pCtrlDatabase)
p$V0S813$4 = (pCtrlUserID)
p$V0S813$5 = (pCtrlPassword)
p$V0S813$6 = "N"
Call 'DSU.JobOccrStart'(r$V0S813, p$V0S813$1, p$V0S813$2, p$V0S813$3, p$V0S813$4, p$V0S813$5, p$V0S813$6)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccStart_0":@FM:r$V0S813))
IdV0S813%%Result1%%2 = r$V0S813
IdV0S813%%Name%%3 = "DSU.JobOccrStart"
IdV0S813%%Param%%4 = (p$V0S813$1)
IdV0S813%%Param%%5 = (p$V0S813$2)
IdV0S813%%Param%%6 = (p$V0S813$3)
IdV0S813%%Param%%7 = (p$V0S813$4)
IdV0S813%%Param%%8 = (p$V0S813$5)
IdV0S813%%Param%%9 = (p$V0S813$6)
If r$V0S813 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrStart":@FM:r$V0S813), "@JobOccStart_0")
End
If (r$V0S813 <> 0) Then
err$source = "JobOccStart_0"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V0S813:@FM:"DSU.JobOccrStart")
msg$id = "@JobOccStart_0"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrStart"), "@JobOccStart_0")
GoSub L$V0S913$START
GoTo L$RETURN$1
**************************************************
L$V0S913$START:
*** Sequencer "SEQ_00": wait until inputs ready
seq$V0S913$status = 1
seq$V0S913$count += 1
If seq$V0S913$count < 1 Then Return
seq$V0S913$status = 2
GoTo L$V0S926$START
L$V0S913$RETURN$1:
Return
**************************************************
L$V0S926$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_1": Initialize job
jb$V0S926 = "UEPostProcUpdateIB_TRANSACTIONS_1"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcUpdateIB_TRANSACTIONS_1":@FM:jb$V0S926))
h$V0S926 = DSAttachJob(jb$V0S926, DSJ.ERRNONE)
If (Not(h$V0S926)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V0S926:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
h$V0S926 = DSPrepareJob(h$V0S926)
If (Not(h$V0S926)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V0S926:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
L$V0S926$PREPARED:
p$V0S926$1 = (pRunStream)
err$code = DSSetParam(h$V0S926, "pRunStream", p$V0S926$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V0S926, "pTempProcessFilePath", p$V0S926$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$3 = (pRerunFlag)
err$code = DSSetParam(h$V0S926, "pRerunFlag", p$V0S926$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$4 = (pTargetUserID)
err$code = DSSetParam(h$V0S926, "pTargetUserID", p$V0S926$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$5 = (pTargetPassword)
err$code = DSSetParam(h$V0S926, "pTargetPassword", p$V0S926$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
p$V0S926$6 = (pTargetDatabase)
err$code = DSSetParam(h$V0S926, "pTargetDatabase", p$V0S926$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
err$code = DSRunJob(h$V0S926, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V0S926:@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1"; GoTo L$ERROR
End
handle$list<-1> = h$V0S926
id$list<-1> = "V0S926"
GoTo L$V0S913$RETURN$1
**************************************************
L$V0S926$FINISHED:
job$V0S926$status = DSGetJobInfo(h$V0S926, DSJ.JOBSTATUS)
job$V0S926$userstatus = DSGetJobInfo(h$V0S926, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcUpdateIB_TRANSACTIONS_1":@FM:jb$V0S926:@FM:job$V0S926$status))
IdV0S926%%Result2%%10 = job$V0S926$userstatus
IdV0S926%%Result1%%11 = job$V0S926$status
IdV0S926%%Name%%12 = jb$V0S926
If (job$V0S926$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V0S926:@FM:DSTranslateCode(job$V0S926$status)), "@PostProcUpdateIB_TRANSACTIONS_1")
End
rpt$V0S926 = DSMakeJobReport(h$V0S926, 1, "CRLF")
rpt$all := "\n":rpt$V0S926 ;* accumulate job reports
dummy$ = DSDetachJob(h$V0S926)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V0S926), "@PostProcUpdateIB_TRANSACTIONS_1")
If b$Abandoning Then GoTo L$WAITFORJOB
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V0S938$START
If (job$V0S926$status <> DSJS.RUNOK And job$V0S926$status <> DSJS.RUNWARN) Then GoTo L$V0S936$START
L$V0S926$RETURN$2:
GoTo L$WAITFORJOB
**************************************************
L$V0S936$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_1_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_1_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1_Failed"; GoTo L$ERROR
End
p$V0S936$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V0S936$2 = "A"
p$V0S936$3 = (pCtrlDatabase)
p$V0S936$4 = (pCtrlUserID)
p$V0S936$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V0S936, p$V0S936$1, p$V0S936$2, p$V0S936$3, p$V0S936$4, p$V0S936$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_1_Failed":@FM:r$V0S936))
IdV0S936%%Result1%%13 = r$V0S936
IdV0S936%%Name%%14 = "DSU.JobOccrMessage"
IdV0S936%%Param%%15 = (p$V0S936$1)
IdV0S936%%Param%%16 = (p$V0S936$2)
IdV0S936%%Param%%17 = (p$V0S936$3)
IdV0S936%%Param%%18 = (p$V0S936$4)
IdV0S936%%Param%%19 = (p$V0S936$5)
If r$V0S936 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V0S936), "@PostProcUpdateIB_TRANSACTIONS_1_Failed")
End
If (r$V0S936 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_1_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V0S936:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_1_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_1_Failed")
GoTo L$V0S926$RETURN$2
**************************************************
L$V0S938$START:
*** Sequencer "SEQ_01a": wait until inputs ready
seq$V0S938$status = 1
If seq$V0S938$count > 0 Then Return
seq$V0S938$count += 1
seq$V0S938$status = 2
GoTo L$V190S1$START
L$V0S938$RETURN$1:
Return
**************************************************
L$V0S950$START:
*** Sequencer "SEQ_End": wait until inputs ready
seq$V0S950$status = 1
seq$V0S950$count += 1
If seq$V0S950$count < 1 Then Return
seq$V0S950$status = 2
GoTo L$V0S970$START
L$V0S950$RETURN$1:
Return
**************************************************
L$V0S970$START:
*** Activity "JobOccrEndOk": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccrEndOk":@FM:"DSU.JobOccrEnd"))
rtn$ok = DSCheckRoutine("DSU.JobOccrEnd")
If (Not(rtn$ok)) Then
err$source = "JobOccrEndOk"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrEnd")
msg$id = "@JobOccrEndOk"; GoTo L$ERROR
End
p$V0S970$1 = "C"
p$V0S970$2 = (pRunStream)
p$V0S970$3 = (pRunStreamProcessDate)
p$V0S970$4 = (pCtrlDatabase)
p$V0S970$5 = (pCtrlUserID)
p$V0S970$6 = (pCtrlPassword)
p$V0S970$7 = (pTargetDatabase)
p$V0S970$8 = (pTargetUserID)
p$V0S970$9 = (pTargetPassword)
Call 'DSU.JobOccrEnd'(r$V0S970, p$V0S970$1, p$V0S970$2, p$V0S970$3, p$V0S970$4, p$V0S970$5, p$V0S970$6, p$V0S970$7, p$V0S970$8, p$V0S970$9)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccrEndOk":@FM:r$V0S970))
IdV0S970%%Result1%%20 = r$V0S970
IdV0S970%%Name%%21 = "DSU.JobOccrEnd"
IdV0S970%%Param%%22 = (p$V0S970$1)
IdV0S970%%Param%%23 = (p$V0S970$2)
IdV0S970%%Param%%24 = (p$V0S970$3)
IdV0S970%%Param%%25 = (p$V0S970$4)
IdV0S970%%Param%%26 = (p$V0S970$5)
IdV0S970%%Param%%27 = (p$V0S970$6)
IdV0S970%%Param%%28 = (p$V0S970$7)
IdV0S970%%Param%%29 = (p$V0S970$8)
IdV0S970%%Param%%30 = (p$V0S970$9)
If r$V0S970 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrEnd":@FM:r$V0S970), "@JobOccrEndOk")
End
If (r$V0S970 <> 0) Then
err$source = "JobOccrEndOk"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V0S970:@FM:"DSU.JobOccrEnd")
msg$id = "@JobOccrEndOk"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrEnd"), "@JobOccrEndOk")
GoTo L$V0S950$RETURN$1
**************************************************
L$V190S0$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_2_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_2_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_2_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_2_Failed"; GoTo L$ERROR
End
p$V190S0$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V190S0$2 = "A"
p$V190S0$3 = (pCtrlDatabase)
p$V190S0$4 = (pCtrlUserID)
p$V190S0$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V190S0, p$V190S0$1, p$V190S0$2, p$V190S0$3, p$V190S0$4, p$V190S0$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_2_Failed":@FM:r$V190S0))
IdV190S0%%Result1%%31 = r$V190S0
IdV190S0%%Name%%32 = "DSU.JobOccrMessage"
IdV190S0%%Param%%33 = (p$V190S0$1)
IdV190S0%%Param%%34 = (p$V190S0$2)
IdV190S0%%Param%%35 = (p$V190S0$3)
IdV190S0%%Param%%36 = (p$V190S0$4)
IdV190S0%%Param%%37 = (p$V190S0$5)
If r$V190S0 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V190S0), "@PostProcUpdateIB_TRANSACTIONS_2_Failed")
End
If (r$V190S0 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_2_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V190S0:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_2_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_2_Failed")
GoTo L$V190S1$RETURN$2
**************************************************
L$V190S1$START:
*** Activity "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2": Initialize job
jb$V190S1 = "UEPostProcUpdateIB_SWAP_TRANS_LEGS_2"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2":@FM:jb$V190S1))
h$V190S1 = DSAttachJob(jb$V190S1, DSJ.ERRNONE)
If (Not(h$V190S1)) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V190S1:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
h$V190S1 = DSPrepareJob(h$V190S1)
If (Not(h$V190S1)) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V190S1:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
L$V190S1$PREPARED:
p$V190S1$1 = (pRunStream)
err$code = DSSetParam(h$V190S1, "pRunStream", p$V190S1$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V190S1, "pTempProcessFilePath", p$V190S1$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$3 = (pRerunFlag)
err$code = DSSetParam(h$V190S1, "pRerunFlag", p$V190S1$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$4 = (pTargetUserID)
err$code = DSSetParam(h$V190S1, "pTargetUserID", p$V190S1$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$5 = (pTargetPassword)
err$code = DSSetParam(h$V190S1, "pTargetPassword", p$V190S1$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
p$V190S1$6 = (pTargetDatabase)
err$code = DSSetParam(h$V190S1, "pTargetDatabase", p$V190S1$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
err$code = DSRunJob(h$V190S1, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V190S1:@FM:err$code)
msg$id = "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2"; GoTo L$ERROR
End
handle$list<-1> = h$V190S1
id$list<-1> = "V190S1"
GoTo L$V0S938$RETURN$1
**************************************************
L$V190S1$FINISHED:
job$V190S1$status = DSGetJobInfo(h$V190S1, DSJ.JOBSTATUS)
job$V190S1$userstatus = DSGetJobInfo(h$V190S1, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2":@FM:jb$V190S1:@FM:job$V190S1$status))
IdV190S1%%Result2%%38 = job$V190S1$userstatus
IdV190S1%%Result1%%39 = job$V190S1$status
IdV190S1%%Name%%40 = jb$V190S1
If (job$V190S1$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V190S1:@FM:DSTranslateCode(job$V190S1$status)), "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2")
End
rpt$V190S1 = DSMakeJobReport(h$V190S1, 1, "CRLF")
rpt$all := "\n":rpt$V190S1 ;* accumulate job reports
dummy$ = DSDetachJob(h$V190S1)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V190S1), "@PostProcUpdateIB_SWAP_TRANSACTION_LEGS_2")
If b$Abandoning Then GoTo L$WAITFORJOB
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V0S991$START
If (job$V190S1$status <> DSJS.RUNOK And job$V190S1$status <> DSJS.RUNWARN) Then GoTo L$V190S0$START
L$V190S1$RETURN$2:
GoTo L$WAITFORJOB
**************************************************
L$V191S0$START:
*** Activity "PostProcDeleteIB_CASHFLOWS_4": Initialize job
jb$V191S0 = "UEPostProcDeleteIB_CASHFLOWS_4"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcDeleteIB_CASHFLOWS_4":@FM:jb$V191S0))
h$V191S0 = DSAttachJob(jb$V191S0, DSJ.ERRNONE)
If (Not(h$V191S0)) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V191S0:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
h$V191S0 = DSPrepareJob(h$V191S0)
If (Not(h$V191S0)) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V191S0:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
L$V191S0$PREPARED:
p$V191S0$1 = (pRunStream)
err$code = DSSetParam(h$V191S0, "pRunStream", p$V191S0$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V191S0, "pTempProcessFilePath", p$V191S0$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$3 = (pRerunFlag)
err$code = DSSetParam(h$V191S0, "pRerunFlag", p$V191S0$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$4 = (pTargetUserID)
err$code = DSSetParam(h$V191S0, "pTargetUserID", p$V191S0$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$5 = (pTargetPassword)
err$code = DSSetParam(h$V191S0, "pTargetPassword", p$V191S0$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
p$V191S0$6 = (pTargetDatabase)
err$code = DSSetParam(h$V191S0, "pTargetDatabase", p$V191S0$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
err$code = DSRunJob(h$V191S0, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcDeleteIB_CASHFLOWS_4"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V191S0:@FM:err$code)
msg$id = "@PostProcDeleteIB_CASHFLOWS_4"; GoTo L$ERROR
End
handle$list<-1> = h$V191S0
id$list<-1> = "V191S0"
GoTo L$V191S4$RETURN$1
**************************************************
L$V191S0$FINISHED:
job$V191S0$status = DSGetJobInfo(h$V191S0, DSJ.JOBSTATUS)
job$V191S0$userstatus = DSGetJobInfo(h$V191S0, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcDeleteIB_CASHFLOWS_4":@FM:jb$V191S0:@FM:job$V191S0$status))
IdV191S0%%Result2%%41 = job$V191S0$userstatus
IdV191S0%%Result1%%42 = job$V191S0$status
IdV191S0%%Name%%43 = jb$V191S0
If (job$V191S0$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V191S0:@FM:DSTranslateCode(job$V191S0$status)), "@PostProcDeleteIB_CASHFLOWS_4")
End
rpt$V191S0 = DSMakeJobReport(h$V191S0, 1, "CRLF")
rpt$all := "\n":rpt$V191S0 ;* accumulate job reports
dummy$ = DSDetachJob(h$V191S0)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V191S0), "@PostProcDeleteIB_CASHFLOWS_4")
If b$Abandoning Then GoTo L$WAITFORJOB
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V0S1007$START
If (job$V191S0$status <> DSJS.RUNOK And job$V191S0$status <> DSJS.RUNWARN) Then GoTo L$V191S3$START
L$V191S0$RETURN$2:
GoTo L$WAITFORJOB
**************************************************
L$V191S3$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_4_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_4_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_4_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_4_Failed"; GoTo L$ERROR
End
p$V191S3$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V191S3$2 = "A"
p$V191S3$3 = (pCtrlDatabase)
p$V191S3$4 = (pCtrlUserID)
p$V191S3$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V191S3, p$V191S3$1, p$V191S3$2, p$V191S3$3, p$V191S3$4, p$V191S3$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_4_Failed":@FM:r$V191S3))
IdV191S3%%Result1%%44 = r$V191S3
IdV191S3%%Name%%45 = "DSU.JobOccrMessage"
IdV191S3%%Param%%46 = (p$V191S3$1)
IdV191S3%%Param%%47 = (p$V191S3$2)
IdV191S3%%Param%%48 = (p$V191S3$3)
IdV191S3%%Param%%49 = (p$V191S3$4)
IdV191S3%%Param%%50 = (p$V191S3$5)
If r$V191S3 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V191S3), "@PostProcUpdateIB_TRANSACTIONS_4_Failed")
End
If (r$V191S3 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_4_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V191S3:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_4_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_4_Failed")
GoTo L$V191S0$RETURN$2
**************************************************
L$V191S4$START:
*** Sequencer "SEQ_03a": wait until inputs ready
seq$V191S4$status = 1
If seq$V191S4$count > 0 Then Return
seq$V191S4$count += 1
seq$V191S4$status = 2
GoTo L$V191S0$START
L$V191S4$RETURN$1:
Return
**************************************************
L$V191S5$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_3": Initialize job
jb$V191S5 = "UEPostProcUpdateIB_TRANSACTIONS_3"
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0057\%1 (JOB %2) started", "PostProcUpdateIB_TRANSACTIONS_3":@FM:jb$V191S5))
h$V191S5 = DSAttachJob(jb$V191S5, DSJ.ERRNONE)
If (Not(h$V191S5)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0001\Error calling DSAttachJob(%1)<L>%2", jb$V191S5:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
h$V191S5 = DSPrepareJob(h$V191S5)
If (Not(h$V191S5)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0012\Error calling DSPrepareJob(%1)<L>%2", jb$V191S5:@FM:DSGetLastErrorMsg())
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
L$V191S5$PREPARED:
p$V191S5$1 = (pRunStream)
err$code = DSSetParam(h$V191S5, "pRunStream", p$V191S5$1)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRunStream":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$2 = (pTempProcessFilePath)
err$code = DSSetParam(h$V191S5, "pTempProcessFilePath", p$V191S5$2)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTempProcessFilePath":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$3 = (pRerunFlag)
err$code = DSSetParam(h$V191S5, "pRerunFlag", p$V191S5$3)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pRerunFlag":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$4 = (pTargetUserID)
err$code = DSSetParam(h$V191S5, "pTargetUserID", p$V191S5$4)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetUserID":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$5 = (pTargetPassword)
err$code = DSSetParam(h$V191S5, "pTargetPassword", p$V191S5$5)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetPassword":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
p$V191S5$6 = (pTargetDatabase)
err$code = DSSetParam(h$V191S5, "pTargetDatabase", p$V191S5$6)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0002\Error calling DSSetParam(%1), code=%2[E]", "pTargetDatabase":@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
err$code = DSRunJob(h$V191S5, DSJ.RUNNORMAL)
If (err$code <> DSJE.NOERROR) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0003\Error calling DSRunJob(%1), code=%2[E]", jb$V191S5:@FM:err$code)
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3"; GoTo L$ERROR
End
handle$list<-1> = h$V191S5
id$list<-1> = "V191S5"
GoTo L$V0S991$RETURN$1
**************************************************
L$V191S5$FINISHED:
job$V191S5$status = DSGetJobInfo(h$V191S5, DSJ.JOBSTATUS)
job$V191S5$userstatus = DSGetJobInfo(h$V191S5, DSJ.USERSTATUS)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0063\%1 (JOB %2) finished, status=%3[E]", "PostProcUpdateIB_TRANSACTIONS_3":@FM:jb$V191S5:@FM:job$V191S5$status))
IdV191S5%%Result2%%51 = job$V191S5$userstatus
IdV191S5%%Result1%%52 = job$V191S5$status
IdV191S5%%Name%%53 = jb$V191S5
If (job$V191S5$status <> DSJS.RUNOK) Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0030\Job %1 did not finish OK, status = '%2'", jb$V191S5:@FM:DSTranslateCode(job$V191S5$status)), "@PostProcUpdateIB_TRANSACTIONS_3")
End
rpt$V191S5 = DSMakeJobReport(h$V191S5, 1, "CRLF")
rpt$all := "\n":rpt$V191S5 ;* accumulate job reports
dummy$ = DSDetachJob(h$V191S5)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0038\Omitted checkpoint for run of job '%1'", jb$V191S5), "@PostProcUpdateIB_TRANSACTIONS_3")
If b$Abandoning Then GoTo L$WAITFORJOB
If (job$V191S5$status <> DSJS.RUNOK And job$V191S5$status <> DSJS.RUNWARN) Then GoTo L$V192S0$START
L$V191S5$RETURN$1:
If ("Executed OK" or "Execution finished with Warnings") Then GoSub L$V191S4$START
GoTo L$WAITFORJOB
**************************************************
L$V0S991$START:
*** Sequencer "SEQ_02a": wait until inputs ready
seq$V0S991$status = 1
If seq$V0S991$count > 0 Then Return
seq$V0S991$count += 1
seq$V0S991$status = 2
GoTo L$V191S5$START
L$V0S991$RETURN$1:
Return
**************************************************
L$V192S0$START:
*** Activity "PostProcUpdateIB_TRANSACTIONS_3_Failed": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "PostProcUpdateIB_TRANSACTIONS_3_Failed":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3_Failed"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3_Failed"; GoTo L$ERROR
End
p$V192S0$1 = "Post-Processing step to Update IB_TRANSACTIONS for " : pRunStream : " has failed."
p$V192S0$2 = "A"
p$V192S0$3 = (pCtrlDatabase)
p$V192S0$4 = (pCtrlUserID)
p$V192S0$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V192S0, p$V192S0$1, p$V192S0$2, p$V192S0$3, p$V192S0$4, p$V192S0$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "PostProcUpdateIB_TRANSACTIONS_3_Failed":@FM:r$V192S0))
IdV192S0%%Result1%%54 = r$V192S0
IdV192S0%%Name%%55 = "DSU.JobOccrMessage"
IdV192S0%%Param%%56 = (p$V192S0$1)
IdV192S0%%Param%%57 = (p$V192S0$2)
IdV192S0%%Param%%58 = (p$V192S0$3)
IdV192S0%%Param%%59 = (p$V192S0$4)
IdV192S0%%Param%%60 = (p$V192S0$5)
If r$V192S0 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V192S0), "@PostProcUpdateIB_TRANSACTIONS_3_Failed")
End
If (r$V192S0 <> 0) Then
err$source = "PostProcUpdateIB_TRANSACTIONS_3_Failed"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V192S0:@FM:"DSU.JobOccrMessage")
msg$id = "@PostProcUpdateIB_TRANSACTIONS_3_Failed"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@PostProcUpdateIB_TRANSACTIONS_3_Failed")
GoTo L$V191S5$RETURN$1
**************************************************
L$V0S1007$START:
*** Sequencer "SEQ_04a": wait until inputs ready
seq$V0S1007$status = 1
If seq$V0S1007$count > 0 Then Return
seq$V0S1007$count += 1
seq$V0S1007$status = 2
GoSub L$V0S950$START
Return
**************************************************
L$V195S0$START:
*** Activity "JobOccrMessageException": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccrMessageException":@FM:"DSU.JobOccrMessage"))
rtn$ok = DSCheckRoutine("DSU.JobOccrMessage")
If (Not(rtn$ok)) Then
err$source = "JobOccrMessageException"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrMessage")
msg$id = "@JobOccrMessageException"; GoTo L$ERROR
End
p$V195S0$1 = (IdV195S6%%UserVar%%1)
p$V195S0$2 = ('I')
p$V195S0$3 = (pCtrlDatabase)
p$V195S0$4 = (pCtrlUserID)
p$V195S0$5 = (pCtrlPassword)
Call 'DSU.JobOccrMessage'(r$V195S0, p$V195S0$1, p$V195S0$2, p$V195S0$3, p$V195S0$4, p$V195S0$5)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccrMessageException":@FM:r$V195S0))
IdV195S0%%Result1%%61 = r$V195S0
IdV195S0%%Name%%62 = "DSU.JobOccrMessage"
IdV195S0%%Param%%63 = (p$V195S0$1)
IdV195S0%%Param%%64 = (p$V195S0$2)
IdV195S0%%Param%%65 = (p$V195S0$3)
IdV195S0%%Param%%66 = (p$V195S0$4)
IdV195S0%%Param%%67 = (p$V195S0$5)
If r$V195S0 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrMessage":@FM:r$V195S0), "@JobOccrMessageException")
End
If (r$V195S0 <> 0) Then
err$source = "JobOccrMessageException"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V195S0:@FM:"DSU.JobOccrMessage")
msg$id = "@JobOccrMessageException"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrMessage"), "@JobOccrMessageException")
GoTo L$V195S5$START
L$V195S0$RETURN$1:
GoTo L$V195S6$RETURN$1
**************************************************
L$V195S1$START:
*** Activity "JobOccrEndNOK": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "JobOccrEndNOK":@FM:"DSU.JobOccrEnd"))
rtn$ok = DSCheckRoutine("DSU.JobOccrEnd")
If (Not(rtn$ok)) Then
err$source = "JobOccrEndNOK"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSU.JobOccrEnd")
msg$id = "@JobOccrEndNOK"; GoTo L$ERROR
End
p$V195S1$1 = ('A')
p$V195S1$2 = (pRunStream)
p$V195S1$3 = (pRunStreamProcessDate)
p$V195S1$4 = (pCtrlDatabase)
p$V195S1$5 = (pCtrlUserID)
p$V195S1$6 = (pCtrlPassword)
p$V195S1$7 = (pTargetDatabase)
p$V195S1$8 = (pTargetUserID)
p$V195S1$9 = (pTargetPassword)
Call 'DSU.JobOccrEnd'(r$V195S1, p$V195S1$1, p$V195S1$2, p$V195S1$3, p$V195S1$4, p$V195S1$5, p$V195S1$6, p$V195S1$7, p$V195S1$8, p$V195S1$9)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "JobOccrEndNOK":@FM:r$V195S1))
IdV195S1%%Result1%%68 = r$V195S1
IdV195S1%%Name%%69 = "DSU.JobOccrEnd"
IdV195S1%%Param%%70 = (p$V195S1$1)
IdV195S1%%Param%%71 = (p$V195S1$2)
IdV195S1%%Param%%72 = (p$V195S1$3)
IdV195S1%%Param%%73 = (p$V195S1$4)
IdV195S1%%Param%%74 = (p$V195S1$5)
IdV195S1%%Param%%75 = (p$V195S1$6)
IdV195S1%%Param%%76 = (p$V195S1$7)
IdV195S1%%Param%%77 = (p$V195S1$8)
IdV195S1%%Param%%78 = (p$V195S1$9)
If r$V195S1 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSU.JobOccrEnd":@FM:r$V195S1), "@JobOccrEndNOK")
End
If (r$V195S1 <> 0) Then
err$source = "JobOccrEndNOK"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V195S1:@FM:"DSU.JobOccrEnd")
msg$id = "@JobOccrEndNOK"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSU.JobOccrEnd"), "@JobOccrEndNOK")
GoTo L$V195S6$START
L$V195S1$RETURN$1:
GoTo L$V195S2$RETURN$1
**************************************************
L$V195S2$START:
*** Decision "ExceptionHandler"
GoTo L$V195S1$START
L$V195S2$RETURN$1:
GoTo L$WAITFORJOB
**************************************************
L$V195S3$START:
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0065\%1 Executed", "Terminate"))
* Send stop request to any outstanding child jobs
For index$ = 1 To DCount(handle$list, @FM)
handle$ = handle$list<index$>
If handle$ <> "" Then
job$name = DSGetJobInfo(handle$, DSJ.JOBNAME)
job$invid = DSGetJobInfo(handle$, DSJ.JOBINVOCATIONID)
if job$invid <> "" Then job$name = job$name:".":job$invid
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0019\Sending STOP request to job: %1", job$name), "@Terminate")
dummy$ = DSStopJob(handle$)
End
Next index$
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0069\Sequence terminated", ""))
Call DSLogInfo(summary$, "@Coordinator")
Call DSLogFatal(DSMakeMsg("DSTAGE_JSG_M_0020\Sequence abort requested", ""), "@Terminate")
**************************************************
L$V195S5$START:
*** Activity "Notify": Call routine
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0058\%1 (ROUTINE %2) started", "Notify":@FM:"DSSendMail"))
rtn$ok = DSCheckRoutine("DSSendMail")
If (Not(rtn$ok)) Then
err$source = "Notify"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0005\BASIC routine is not cataloged: %1", "DSSendMail")
msg$id = "@Notify"; GoTo L$ERROR
End
p$V195S5$0 = "To:":pRecipientMailAddress:"\nFrom:":pSenderMailAddress:"\nSubject:DataStage job ":IdV195S6%%UserVar%%0:" has failed in activity ":IdV195S2%%Param%%79:".\nServer:":pSMTPServer:"\nBody:This is an automatically generated email from DataStage. Do not reply.\n":rpt$all
Call 'DSSendMail'(r$V195S5, p$V195S5$0)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0064\%1 finished, reply=%2", "Notify":@FM:r$V195S5))
If r$V195S5 <> 0 Then
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0041\Routine %1 did not finish OK, return code = '%2'", "DSSendMail":@FM:r$V195S5), "@Notify")
End
If (r$V195S5 <> 0) Then
err$source = "Notify"; err$number = 1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0042\Unhandled failure (%1) encountered calling routine %2", r$V195S5:@FM:"DSSendMail")
msg$id = "@Notify"; GoTo L$ERROR
End
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0039\Omitted checkpoint for call of routine '%1'", "DSSendMail"), "@Notify")
GoTo L$V195S3$START
L$V195S5$RETURN$1:
GoTo L$V195S0$RETURN$1
**************************************************
L$V195S6$START:
*** Set user variables: "UserVarsE"
IdV195S6%%UserVar%%0 = (DSJobName : ( If Len(DSJobInvocationId) > 1 then "." else "") : DSJobInvocationId)
IdV195S6%%UserVar%%1 = ('DataStage job has failed in activity ' : IdV195S2%%Param%%79 : '.')
GoTo L$V195S0$START
L$V195S6$RETURN$1:
GoTo L$V195S1$RETURN$1
**************************************************
L$WAITFORJOB:
If handle$list = "" Then GoTo L$FINISH
handle$ = DSWaitForJob(handle$list)
If handle$ = 0 Then handle$ = handle$list<1>
Locate handle$ In handle$list Setting index$ Then
id$ = id$list<index$>
Del id$list<index$>; Del handle$list<index$>
b$Abandoning = abort$list<index$>; Del abort$list<index$>
Begin Case
Case id$ = "V0S926"
GoTo L$V0S926$FINISHED
Case id$ = "V190S1"
GoTo L$V190S1$FINISHED
Case id$ = "V191S0"
GoTo L$V191S0$FINISHED
Case id$ = "V191S5"
GoTo L$V191S5$FINISHED
End Case
End
* Error if fall though
handle$list = ""
err$source = "@Coordinator"; err$number = -1
msg$ = DSMakeMsg("DSTAGE_JSG_M_0008\Error calling DSWaitForJob(), code=%1[E]", handle$)
msg$id = "@Coordinator"; GoTo L$ERROR
**************************************************
L$ERROR:
IdV195S2%%Param%%79 = err$source
IdV195S2%%Param%%80 = err$number
IdV195S2%%Param%%81 = msg$
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0009\Controller problem: %1", msg$), msg$id)
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0052\Exception raised: %1", msg$id:", ":msg$))
If Not(b$InErrorRef) Then
dummy$ = DSCheckPointSetValue(DSJ.ME, "!", DSMakeMsg("DSTAGE_JSG_M_0031\Failed at: %1, Reason=%2", err$source:@FM:msg$))
End
abort$list = Ifs(handle$list, Str(1:@FM, DCount(handle$list, @FM)), "")
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0053\Exception handler started", ""))
If Not(b$InErrorRef) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0010\Will execute error activity: %1", "ExceptionHandler"), msg$id)
b$InErrorRef = @True
b$NumStarted = 1
GoTo L$V195S2$START
End Else
Call DSLogWarn(DSMakeMsg("DSTAGE_JSG_M_0011\Error while executing error activity: %1", "ExceptionHandler"), msg$id)
End
b$Abandoning = @True
GoTo L$WAITFORJOB
L$ABORT:
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0055\Sequence failed (restartable)", ""))
Call DSLogInfo(summary$, "@Coordinator")
Call DSLogFatal(DSMakeMsg("DSTAGE_JSG_M_0014\Sequence job (restartable) will abort due to previous unrecoverable errors", ""), "@Coordinator")
**************************************************
L$FINISH:
If b$Abandoning Then GoTo L$ABORT
*** At successful exit remove checkpoint record
If Not(b$InErrorRef) And DSCheckPointExists(DSJ.ME, cp$dtm) Then
dummy$ = DSCheckPointDelete(DSJ.ME)
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0018\Removed checkpoint record at successful completion of sequence", ""), "@Coordinator")
End
If (seq$V0S913$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_00"), "@Coordinator")
End
If (seq$V0S938$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_01a"), "@Coordinator")
End
If (seq$V0S950$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_End"), "@Coordinator")
End
If (seq$V191S4$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_03a"), "@Coordinator")
End
If (seq$V0S991$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_02a"), "@Coordinator")
End
If (seq$V0S1007$status = 1) Then
Call DSLogInfo(DSMakeMsg("DSTAGE_JSG_M_0072\Note: Sequencer '%1' was entered, but never exited", "SEQ_04a"), "@Coordinator")
End
summary$<1,-1> = Time$$:Convert(@VM, " ", DSMakeMsg("DSTAGE_JSG_M_0054\Sequence finished OK", ""))
Call DSLogInfo(summary$, "@Coordinator")
L$EXIT: Return To L$EXIT
][/code]