Skip to content

Commit 5a401b2

Browse files
Fix: Rename triggerMetadata to triggerReason for clarity
Co-Authored-By: Chris Li <chris.li.2046@gmail.com>
1 parent 87e47c4 commit 5a401b2

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

core/taskengine/executor.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -81,12 +81,12 @@ func (x *TaskExecutor) RunTask(task *model.Task, queueData *QueueExecutionData)
8181
return nil, fmt.Errorf("internal error: invalid execution id")
8282
}
8383

84-
triggerMetadata := GetTriggerReasonOrDefault(queueData.Reason, task.Id, x.logger)
84+
triggerReason := GetTriggerReasonOrDefault(queueData.Reason, task.Id, x.logger)
8585

8686
secrets, _ := LoadSecretForTask(x.db, task)
8787
vm, err := NewVMWithData(
8888
task,
89-
triggerMetadata,
89+
triggerReason,
9090
x.smartWalletConfig,
9191
secrets,
9292
)
@@ -132,7 +132,7 @@ func (x *TaskExecutor) RunTask(task *model.Task, queueData *QueueExecutionData)
132132
Success: runTaskErr == nil,
133133
Error: "",
134134
Steps: vm.ExecutionLogs,
135-
Reason: triggerMetadata,
135+
Reason: triggerReason,
136136
TriggerName: task.Trigger.Name,
137137

138138
// Note: despite the name OutputData, this isn't output data of the task, it's the parsed and enrich data based on the event
@@ -141,7 +141,7 @@ func (x *TaskExecutor) RunTask(task *model.Task, queueData *QueueExecutionData)
141141
}
142142

143143
if runTaskErr != nil {
144-
x.logger.Error("error executing task", "error", err, "runError", runTaskErr, "task_id", task.Id, "triggermark", triggerMetadata)
144+
x.logger.Error("error executing task", "error", err, "runError", runTaskErr, "task_id", task.Id, "triggermark", triggerReason)
145145
execution.Error = runTaskErr.Error()
146146
}
147147

@@ -169,7 +169,7 @@ func (x *TaskExecutor) RunTask(task *model.Task, queueData *QueueExecutionData)
169169
}
170170

171171
if runTaskErr == nil {
172-
x.logger.Info("succesfully executing task", "task_id", task.Id, "triggermark", triggerMetadata)
172+
x.logger.Info("succesfully executing task", "task_id", task.Id, "triggermark", triggerReason)
173173
return execution, nil
174174
}
175175
return execution, fmt.Errorf("Error executing task %s: %v", task.Id, runTaskErr)

0 commit comments

Comments
 (0)