Function saveTaskToInventory

pkg/queue/task.go:489–533

(ctx context.Context, task Task, newStatus task.Status, q *queue)

}

func saveTaskToInventory(ctx context.Context, task Task, newStatus task.Status, q *queue) error {
	var (
		errStr     string
		errHistory []string
	)
	if err := task.Error(); err != nil {
		errStr = err.Error()
	}

	errHistory = lo.Map(task.ErrorHistory(), func(err error, index int) string {
		return err.Error()
	})

	args := &inventory.TaskArgs{
		Status: newStatus,
		Type:   task.Type(),
		PublicState: &types.TaskPublicState{
			RetryCount:       task.Retried(),
			ExecutedDuration: task.Executed(),
			ErrorHistory:     errHistory,
			Error:            errStr,
			ResumeTime:       task.ResumeTime(),
		},
		PrivateState:  task.State(),
		OwnerID:       task.Owner().ID,
		CorrelationID: logging.CorrelationID(ctx),
	}

	var (
		res *ent.Task
		err error
	)

	if !task.Persisted() {
		res, err = q.taskClient.New(ctx, args)
	} else {
		res, err = q.taskClient.Update(ctx, task.Model(), args)
	}
	if err != nil {
		return fmt.Errorf("failed to persist Task into DB: %w", err)
	}

	task.OnPersisted(res)
	return nil
}