Method GetPendingTasks

inventory/task.go:165–187

(ctx context.Context, taskType ...string)

}

func (c *taskClient) GetPendingTasks(ctx context.Context, taskType ...string) ([]*ent.Task, error) {
	tasks, err := withTaskEagerLoading(ctx, c.client.Task.Query()).
		Where(task.StatusIn(task.StatusProcessing, task.StatusQueued, task.StatusSuspending)).
		Where(task.TypeIn(taskType...)).
		All(ctx)
	if err != nil {
		return nil, err
	}

	// Anonymous user is not loaded by default, so we need to load it manually.
	userClient := NewUserClient(c.client)
	anonymous, err := userClient.AnonymousUser(ctx)
	for _, t := range tasks {
		if t.UserTasks == 0 {
			if err != nil {
				return nil, err
			}
			t.SetUser(anonymous)
		}
	}

	return tasks, nil
}

func (c *taskClient) GetTaskByID(ctx context.Context, taskID int) (*ent.Task, error) {
	return withTaskEagerLoading(ctx, c.client.Task.Query()).