logpath

package

v2.12.0 Latest Latest Go to latest Published: Aug 6, 2026 License: GPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func Generate(ctx context.Context, baseLogDir, dagLogDir, dagName, dagRunID string) (string, error)

Generate expands the configured log directories, creates the DAG-run log directory if needed, and returns the full log file path.

func GenerateDir(ctx context.Context, baseDir, dagDir, dagName, dagRunID string) (string, error)

GenerateDir expands the configured directories, creates the DAG-run directory if needed, and returns the per-run directory path.

type Config struct {
	BaseDir   string
	DAGLogDir string
	Name      string
	DAGRunID  string
}

Config defines configuration for DAG run log file creation.

func (cfg Config) LogDir() (string, error)

LogDir is kept for backward compatibility with log-specific call sites.

func (cfg Config) LogFile() string

LogFile constructs the scheduler log filename using the current timestamp and a truncated DAG-run ID.

func (cfg Config) RunDir() (string, error)

RunDir creates and returns the per-run directory based on the configuration.

func (cfg Config) Validate() error

Validate checks that essential fields are provided.