Skip to content

edges

Chain edge definitions.

Edges connect stage nodes and declare how the output of one stage becomes the input of the next. For stage flows within a single unit of work the transformation is the identity: the same generation object carries its own results forward. Semantic edges that build a new unit of work from a finished one (e.g., text-to-image prompt chaining) share this class and override transform-style behavior in later phases.

ChainEdge dataclass

A directed connection between two stage nodes.

Source code in horde_sdk/worker/chaining/edges.py 
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
@dataclass(frozen=True)
class ChainEdge:
    """A directed connection between two stage nodes."""

    kind: CHAIN_EDGE_KIND
    """The kind of hand-off this edge represents."""

    source: ChainNodeHandle
    """The node whose completion feeds this edge."""

    target: ChainNodeHandle
    """The node that becomes eligible when this edge fires."""

    def accepts(self, source_progress: GENERATION_PROGRESS) -> bool:
        """Whether the edge may fire given the source stage's generation progress.

        The default edge fires on any non-failing progress; subclasses may narrow this.

        Args:
            source_progress (GENERATION_PROGRESS): The progress reported at the source stage's completion.

        Returns:
            bool: True when the edge may fire.
        """
        return not GENERATION_PROGRESS.is_state_failing(source_progress)

kind instance-attribute 

kind: CHAIN_EDGE_KIND

The kind of hand-off this edge represents.

source instance-attribute 

source: ChainNodeHandle

The node whose completion feeds this edge.

target instance-attribute 

target: ChainNodeHandle

The node that becomes eligible when this edge fires.

__init__ 

__init__(
    kind: CHAIN_EDGE_KIND,
    source: ChainNodeHandle,
    target: ChainNodeHandle,
) -> None

accepts 

accepts(source_progress: GENERATION_PROGRESS) -> bool

Whether the edge may fire given the source stage's generation progress.

The default edge fires on any non-failing progress; subclasses may narrow this.

Parameters:

  • source_progress (GENERATION_PROGRESS) –

    The progress reported at the source stage's completion.

Returns:

  • bool ( bool ) –

    True when the edge may fire.

Source code in horde_sdk/worker/chaining/edges.py 
31
32
33
34
35
36
37
38
39
40
41
42
def accepts(self, source_progress: GENERATION_PROGRESS) -> bool:
    """Whether the edge may fire given the source stage's generation progress.

    The default edge fires on any non-failing progress; subclasses may narrow this.

    Args:
        source_progress (GENERATION_PROGRESS): The progress reported at the source stage's completion.

    Returns:
        bool: True when the edge may fire.
    """
    return not GENERATION_PROGRESS.is_state_failing(source_progress)