dispatch

package
v2.11.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 31, 2026 License: GPL-3.0 Imports: 2 Imported by: 0

Documentation

Overview

Package dispatch holds control-plane policy for deciding how a DAG run is executed. It is platform code: it combines language-level DAG fields with runtime configuration to choose between local and coordinator-dispatched execution.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ShouldDispatchToCoordinator

func ShouldDispatchToCoordinator(dag *core.DAG, hasCoordinator bool, defaultMode config.ExecutionMode) bool

ShouldDispatchToCoordinator decides whether a DAG should be dispatched to the coordinator for distributed execution.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL