Method taskObserver

internal/extension/host_api_tasks.go:481–489

()

}

func (h *HostAPIHandler) taskObserver() (hostAPIObserver, error) {
	if h == nil {
		return nil, errors.New("extension: host api handler is required")
	}
	if h.observer == nil {
		return nil, errors.New("extension: task observer is not configured")
	}
	return h.observer, nil
}

func (h *HostAPIHandler) taskManagerAndActor(ctx context.Context) (hostAPITaskManager, taskpkg.ActorContext, error) {
	manager, err := h.taskManager()