Documentation
¶
Index ¶
- Constants
- func ForeachItemDir(stepDir, itemPath string) (string, error)
- func ForeachItemPath(parent string, index int) string
- func ForeachNestedParent(itemPath, bodyStepName string) string
- func ForeachParentDir(stepDir, parent string) (string, error)
- func ForeachStepDir(stepLogFile, stepName string) string
- func Generate(ctx context.Context, baseLogDir, dagLogDir, dagName, dagRunID string) (string, error)
- type Config
Constants ¶
const ( // ForeachLogDirName is the directory, next to a foreach step's own log // files, that holds the log files of its item bodies. ForeachLogDirName = "foreach" // ForeachItemsFile lists the expanded items of a foreach step. It lives // in the step's foreach directory. ForeachItemsFile = "items.json" // ForeachItemStatusFile records an item's body run. It lives in the // item's directory. ForeachItemStatusFile = "status.json" )
Variables ¶
This section is empty.
Functions ¶
func ForeachItemDir ¶
ForeachItemDir resolves an item path to its directory under stepDir. A path is "<index>" for a top-level item and "<index>.<bodyStep>.<index>" for an item of a nested foreach, where <bodyStep> is the safe name of the body step. Every segment is validated so the result stays inside stepDir.
func ForeachItemPath ¶
ForeachItemPath builds the item path of an item nested under parent. An empty parent addresses a top-level item.
func ForeachNestedParent ¶
ForeachNestedParent builds the parent path for the items of a foreach body step running inside item itemPath.
func ForeachParentDir ¶
ForeachParentDir resolves a parent path to the foreach directory of the nested step it names. An empty parent resolves to stepDir itself.
func ForeachStepDir ¶
ForeachStepDir returns the directory holding the item bodies of a foreach step whose own log file is stepLogFile.
Types ¶
type Config ¶
Config defines configuration for DAG run log file creation.
func (Config) LogFile ¶
LogFile constructs the scheduler log filename using the current timestamp and a truncated DAG-run ID.
Source Files