diff --git a/utils/utils.go b/utils/utils.go index c3e3922..2faa38b 100644 --- a/utils/utils.go +++ b/utils/utils.go @@ -17,11 +17,13 @@ var ( onceLogger sync.Once onceWF sync.Once ) + func GetExecution(exec_id string) *workflow_execution.WorkflowExecution { res := oclib.NewRequest(oclib.LibDataEnum(oclib.WORKFLOW_EXECUTION), "", conf.GetConfig().PeerID, []string{}, nil).LoadOne(exec_id) if res.Code != 200 { logger := oclib.GetLogger() - logger.Error().Msg("Could not retrieve workflow ID from execution ID " + exec_id) + logger.Error().Msg("Error retrieving execution " + exec_id) + logger.Error().Msg(res.Err) return nil } return res.ToWorkflowExecution()