@@ -71,9 +71,9 @@ func (impl *HandlerServiceImpl) preparePrePostCdWorkflowRequest(ctx context.Cont
71
71
if stageType == types .POST {
72
72
workflowType = types .POST_CD_WORKFLOW_TYPE
73
73
}
74
- workflowRequest , err := impl .workflowTriggerAuditService .GetWorkflowRequestFromSnapshotForRetrigger (runner .Id , workflowType )
74
+ workflowRequest , err := impl .workflowTriggerAuditService .GetWorkflowRequestFromSnapshotForRetrigger (runner .RefCdWorkflowRunnerId , workflowType )
75
75
if err != nil {
76
- impl .logger .Errorw ("error retrieving workflow request from snapshot for pre/post cd stage type" , "workflowType" , workflowType , "cdWorkflowId " , runner .CdWorkflow . Id , "err" , err )
76
+ impl .logger .Errorw ("error retrieving workflow request from snapshot for pre/post cd stage type" , "workflowType" , workflowType , "refCdWorkflowRunnerId " , runner .RefCdWorkflowRunnerId , "err" , err )
77
77
return nil , err
78
78
}
79
79
cdStageWorkflowRequest = workflowRequest
@@ -82,7 +82,7 @@ func (impl *HandlerServiceImpl) preparePrePostCdWorkflowRequest(ctx context.Cont
82
82
} else {
83
83
cdStageWorkflowRequest , err = impl .getPrePostCdStageWorkflowRequest (ctx , runner , cdWf , request .Pipeline , env , request .Artifact , stageType , envDeploymentConfig , request .TriggeredBy )
84
84
if err != nil {
85
- impl .logger .Errorw ("error retrieving workflow request from snapshot for pre/post cd stage type" , "stageType" , stageType , "cdWorkflowId " , runner .CdWorkflow . Id , "err" , err )
85
+ impl .logger .Errorw ("error retrieving workflow request from snapshot for pre/post cd stage type" , "stageType" , stageType , "refCdWorkflowRunnerId " , runner .RefCdWorkflowRunnerId , "err" , err )
86
86
return nil , err
87
87
}
88
88
}
0 commit comments