Initialize self. See help(type(self)) for accurate signature.

Inverse of propagate_tags for resource edges: remove RESOURCE_PROPAGATED copies from views and TASK_PROPAGATED copies from next resources, then recurse downstream.

Wrap the current entities as a depth-0 NavigableEntitySet.

Return the wrapped entities as a set.

Return the wrapped entities as a list. Order is not guaranteed (the underlying storage is a set).

Return an arbitrary entity from the set, or None if empty.

Useful when the caller knows the navigator wraps a single entity.

Return the direct downstream neighbors of the wrapped entities.

Only one hop is followed (no recursion). Entities of any type listed in requested_entities are merged into a single NavigableEntitySet.

Return every entity transitively reachable downstream.

Traverses the lineage graph breadth-first. Each entity is visited once, annotated with its depth in the returned NavigableEntitySet. Use this for impact analysis ("what entities would be affected"). Edge-level provenance is not preserved -- if you need to know which immediate upstream caused a given downstream to be reached, use propagate_tags instead.

Return notes attached to the views of the wrapped resources.

Return resources produced by tasks that consume the wrapped resources as input.

Return all the scenarios that use the resource in a source task or as input of a task

A scenario is considered a "next" scenario if it consumes (uses as input) any resource from this set. Scenarios that only produced resources in this set are excluded, unless they also consume resources produced by a different scenario in the set (which happens when resources from multiple scenarios are batched together).

Return all the scenarios that use the resource in a source task or as input of a task

Return views configured against the wrapped resources.

Return every entity transitively reachable upstream.

Mirror of get_next_entities_recursive but walks the lineage graph in the opposite direction (towards ancestors).

Return the direct upstream notes. Empty by default; overridden by subclasses.

Return resources consumed as input by the tasks that produced the wrapped resources.

Return the scenarios that generated the wrapped resources.

Return the direct upstream views. Empty by default; overridden by subclasses.

Return True if at least one entity is wrapped.

Return True if any direct downstream neighbor exists.

Return True if no entities are wrapped.

Propagate tags along two edge kinds and recurse:

• resource -> view, with origin RESOURCE_PROPAGATED carrying the upstream resource's id;
• resource -> next resource, with origin TASK_PROPAGATED carrying the producing task's id.

See EntityNavigator.propagate_tags for the cache/visited contract.

Build the appropriate concrete navigator for a single entity, by type and id.

Raises if the entity does not exist or if entity_type is unknown.