Remove payload debug
This commit is contained in:
@@ -54,7 +54,7 @@ func (s *Step) AddNextStep(step *Step) {
|
|||||||
const workflowIdParam = "workflowId"
|
const workflowIdParam = "workflowId"
|
||||||
|
|
||||||
func (s *Step) Execute(ctx context.Context, payload map[string]any) error {
|
func (s *Step) Execute(ctx context.Context, payload map[string]any) error {
|
||||||
ersteller.Debug("Executing step ", s.Name, "payload", payload)
|
ersteller.Debug("Executing step ", s.Name)
|
||||||
_, err := s.Queue.Enqueue(ctx, payload, s.MaxRetries, -1, queue.WithWorkflowId(payload[workflowIdParam].(string)))
|
_, err := s.Queue.Enqueue(ctx, payload, s.MaxRetries, -1, queue.WithWorkflowId(payload[workflowIdParam].(string)))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
Reference in New Issue
Block a user