python

Documentation

Index

• Constants
• Variables
• type CommandInstance
• type CommandRunner
  • func (l *CommandRunner) Run(ctx context.Context, repo *git.Repo, command *CommandInstance) error
  • func (l *CommandRunner) RunAnyCommand(ctx context.Context, cmd *exec.Cmd) error
• type LocalOperator
  • func NewLocalOperator(config *config.Config, envVariables map[string]string) *LocalOperator
  • func NewLocalOperatorWithUv(config *config.Config, conn *connection.Manager, ...) *LocalOperator
  • func (o *LocalOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
  • func (o *LocalOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error
• type ModulePathFinder
  • func (m *ModulePathFinder) FindModulePath(repo *git.Repo, executable *pipeline.ExecutableFile) (string, error)
  • func (m *ModulePathFinder) FindRequirementsTxtInPath(path string, executable *pipeline.ExecutableFile) (string, error)
• type NoRequirementsFoundError
  • func (m *NoRequirementsFoundError) Error() string
• type UvChecker
  • func (u *UvChecker) EnsureUvInstalled(ctx context.Context) (string, error)
• type UvPythonRunner
  • func (u *UvPythonRunner) Run(ctx context.Context, execCtx *executionContext) error
  • func (u *UvPythonRunner) RunIngestr(ctx context.Context, args []string, repo *git.Repo) error

Constants

const (
	Shell                   = "/bin/sh"
	ShellSubcommandFlag     = "-c"
	VirtualEnvBinaryFolder  = "bin"
	DefaultPythonExecutable = "python3"
)

const CtxUsePowershellForUv = "use_powershell_for_uv"

const PythonArrowTemplate = `` /* 1092-byte string literal not displayed */

const (
	UvVersion = "0.5.0"
)

const WINDOWS = "windows"

Variables

var AvailablePythonVersions = map[string]bool{
	"3.8":  true,
	"3.9":  true,
	"3.10": true,
	"3.11": true,
	"3.12": true,
	"3.13": true,
}

Types

type CommandInstance

type CommandInstance struct {
	Name    string
	Args    []string
	EnvVars map[string]string
}

type CommandRunner

type CommandRunner struct{}

func (*CommandRunner) Run

func (l *CommandRunner) Run(ctx context.Context, repo *git.Repo, command *CommandInstance) error

func (*CommandRunner) RunAnyCommand

func (l *CommandRunner) RunAnyCommand(ctx context.Context, cmd *exec.Cmd) error

type LocalOperator

type LocalOperator struct {
	// contains filtered or unexported fields
}

func NewLocalOperator

func NewLocalOperator(config *config.Config, envVariables map[string]string) *LocalOperator

func NewLocalOperatorWithUv

func NewLocalOperatorWithUv(config *config.Config, conn *connection.Manager, envVariables map[string]string) *LocalOperator

func (*LocalOperator) Run

func (o *LocalOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

func (*LocalOperator) RunTask

func (o *LocalOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error

type ModulePathFinder

type ModulePathFinder struct {
	PathSeparatorOverride int32
}

func (*ModulePathFinder) FindModulePath

func (m *ModulePathFinder) FindModulePath(repo *git.Repo, executable *pipeline.ExecutableFile) (string, error)

func (*ModulePathFinder) FindRequirementsTxtInPath

func (m *ModulePathFinder) FindRequirementsTxtInPath(path string, executable *pipeline.ExecutableFile) (string, error)

type NoRequirementsFoundError

type NoRequirementsFoundError struct{}

func (*NoRequirementsFoundError) Error

func (m *NoRequirementsFoundError) Error() string

type UvChecker

type UvChecker struct {
	// contains filtered or unexported fields
}

UvChecker handles checking and installing the uv package manager.

func (*UvChecker) EnsureUvInstalled

func (u *UvChecker) EnsureUvInstalled(ctx context.Context) (string, error)

EnsureUvInstalled checks if uv is installed and installs it if not present, then returns the full path of the binary.

type UvPythonRunner

type UvPythonRunner struct {
	Cmd         cmd
	UvInstaller uvInstaller
	// contains filtered or unexported fields
}

func (*UvPythonRunner) Run

func (u *UvPythonRunner) Run(ctx context.Context, execCtx *executionContext) error

func (*UvPythonRunner) RunIngestr

func (u *UvPythonRunner) RunIngestr(ctx context.Context, args []string, repo *git.Repo) error