wfl

package module

Go to main page

Versions in this module

v1

v1.3.7

Aug 20, 2024

v1.3.6

Aug 1, 2024

v1.3.5

Feb 1, 2024

v1.3.4

Dec 29, 2023

v1.3.3

Oct 12, 2023

v1.3.2

Oct 11, 2023

Changes in this version

type Job

+ func (j *Job) WaitWithTimeout(timeout time.Duration) *Job

v1.3.1

May 16, 2023

Changes in this version

+ const PromptJobTemplateConstructorTemplate

+ const PromptTemplateDarwinShellScript

+ const PromptTemplateErrorTransform

+ const PromptTemplateLinuxShellScript

+ const PromptTemplateOutputTransform

+ const PromptTemplatePythonScript

type Job

+ func (j *Job) ErrorP(prompt string) string

+ func (j *Job) OnErrorPanic() *Job

+ func (j *Job) OutputError() string

+ func (j *Job) OutputP(prompt string) string

+ type OpenAIConfig struct

+ Model string

+ RunPMethod RunPBehavior

+ Token string

+ type RunPBehavior string

+ const RunPBehaviorLinuxShellScript

+ const RunPBehaviorMacOSShellScript

+ type TemplatePromptType int

+ const TemplatePromptTypeDarwinShellScript

+ const TemplatePromptTypeLinuxShellScript

+ const TemplatePromptTypePythonScript

type Workflow

+ func (flow *Workflow) TemplateP(prompt string, templateType ...TemplatePromptType) (drmaa2interface.JobTemplate, error)

+ func (w *Workflow) OnErrorPanic() *Workflow

+ func (w *Workflow) WithLLMOpenAI(config OpenAIConfig) *Workflow

v1.3.0

Apr 23, 2023

Changes in this version

type Context

+ func (c *Context) WithUniqueSessionName() *Context

type Job

+ func (j *Job) ForEach(f func(drmaa2interface.Job, interface{}) error, params interface{}) error

+ func (j *Job) OutputsForJobIDs(jobIDs []string) map[string]string

v1.2.14

Apr 10, 2023

v1.2.13

Apr 5, 2023

Changes in this version

+ func RandomFileNameInTempDir() string

v1.2.12

Apr 5, 2023

Changes in this version

type Context

+ ContextTaskID int64

+ JobSessionName string

+ SMType SessionManagerType

+ func (c *Context) GetNextContextTaskID() int64

+ func (c *Context) WithDefaultDockerImage(image string) *Context

+ func (c *Context) WithDefaultJobTemplate(t drmaa2interface.JobTemplate) *Context

+ func (c *Context) WithSessionName(jobSessionName string) *Context

type Job

+ func (j *Job) Output() string

+ type SessionManagerType int

+ const CloudFoundrySessionManager

+ const DefaultSessionManager

+ const DockerSessionManager

+ const ExternalSessionManager

+ const GoogleBatchSessionManager

+ const KubernetesSessionManager

+ const LibDRMAASessionManager

+ const MPIOperatorSessionManager

+ const PodmanSessionManager

+ const RemoteSessionManager

+ const SingularitySessionManager

+ const SlurmSessionManager

v1.2.11

Apr 2, 2023

v1.2.10

Sep 30, 2022

v1.2.9

May 18, 2022

Changes in this version

type Job

+ func (j *Job) ForAll(f func(drmaa2interface.Job, interface{}) error, params interface{}) error

+ func (j *Job) ListAll() []drmaa2interface.Job

+ func (j *Job) RunMatrixT(jt drmaa2interface.JobTemplate, x, y Replacement) *Job

+ type JobTemplateField string

+ const AccountingID

+ const Args

+ const CandidateMachines

+ const DeadlineTime

+ const Email

+ const EmailOnStarted

+ const EmailOnTerminated

+ const ErrorPath

+ const InputPath

+ const JobCategory

+ const JobEnvironment

+ const JobName

+ const JoinFiles

+ const MachineArch

+ const MachineOS

+ const MaxSlots

+ const MinPhysMemory

+ const MinSlots

+ const OutputPath

+ const Priority

+ const QueueName

+ const ReRunnable

+ const RemoteCommand

+ const ReservationID

+ const ResourceLimits

+ const StageInFiles

+ const StageOutFiles

+ const StartTime

+ const SubmitAsHold

+ const WorkingDirectory

type ProcessConfig

+ JobDBFile string

+ PersistentJobStorage bool

+ type Replacement struct

+ Fields []JobTemplateField

+ Pattern string

+ Replacements []string

type Workflow

+ func (w *Workflow) NewJob() *Job

+ func (w *Workflow) RunMatrixT(jt drmaa2interface.JobTemplate, x, y Replacement) *Job

+ func (w *Workflow) SetLogLevel(logLevel log.LogLevel) *Workflow

v1.2.8

Mar 25, 2022

Changes in this version

type Context

+ func NewRemoteContext(cfg RemoteConfig, initParams *client.ClientTrackerParams) *Context

+ type RemoteConfig struct

+ DefaultTemplate drmaa2interface.JobTemplate

+ LocalDBFile string

v1.2.7

Nov 12, 2021

Changes in this version

type Context

+ func NewProcessContextByCfgWithInitParams(cfg ProcessConfig, initParams simpletracker.SimpleTrackerInitParams) *Context

v1.2.6

Apr 8, 2021

Changes in this version

type Job

+ func (j *Job) RunArrayT(begin, end, step, maxParallel int, jt drmaa2interface.JobTemplate) *Job

type Workflow

+ func (w *Workflow) RunArrayJobT(begin, end, step, maxParallel int, jt drmaa2interface.JobTemplate) *Job

v1.2.5

Feb 26, 2021

v1.2.4

Feb 3, 2021

Changes in this version

type Workflow

+ func (w *Workflow) ListJobs() []*Job

v1.2.3

Jan 4, 2021

Changes in this version

type Job

+ func (j *Job) ReapAll() *Job

v1.2.2

Dec 9, 2020

v1.2.1

Nov 25, 2020

Changes in this version

type Job

+ func (j *Job) RunArray(begin, end, step, maxParallel int, cmd string, args ...string) *Job

+ func (j *Job) ThenRunArray(begin, end, step, maxParallel int, cmd string, args ...string) *Job

type Workflow

+ func (w *Workflow) RunArrayJob(begin, end, step, maxParallel int, cmd string, args ...string) *Job

v1.2.0

Aug 20, 2020

Changes in this version

type Context

+ CtxCreationErr error

+ DefaultDockerImage string

+ DefaultTemplate drmaa2interface.JobTemplate

+ SM drmaa2interface.SessionManager

v1.2.0-alpha3

Jul 5, 2020

v1.1.0

Oct 26, 2019

v1.0.3

Sep 6, 2019

v1.0.2

Mar 13, 2019

v1.0.1

Jan 26, 2019

Changes in this version

type CloudFoundryConfig

+ DefaultTemplate drmaa2interface.JobTemplate

type Context

+ func NewSingularityContext() *Context

+ func NewSingularityContextByCfg(cfg SingularityConfig) *Context

type DockerConfig

+ DefaultTemplate drmaa2interface.JobTemplate

type Job

+ func (j *Job) Errored() bool

type KubernetesConfig

+ DefaultTemplate drmaa2interface.JobTemplate

type ProcessConfig

+ DefaultTemplate drmaa2interface.JobTemplate

+ type SingularityConfig struct

+ DBFile string

+ DefaultImage string

+ DefaultTemplate drmaa2interface.JobTemplate

type Workflow

+ func (w *Workflow) Logger() log.Logger

+ func (w *Workflow) SetLogger(log log.Logger) *Workflow

v1.0.0

Aug 25, 2018

Changes in this version

+ func TmpFile() string

+ type CloudFoundryConfig struct

+ APIAddr string

+ DBFile string

+ Password string

+ User string

+ type Context struct

+ func DRMAA2SessionManagerContext(sm drmaa2interface.SessionManager) *Context

+ func ErrorTestContext() *Context

+ func NewCloudFoundryContext() *Context

+ func NewCloudFoundryContextByCfg(cfg CloudFoundryConfig) *Context

+ func NewDockerContext() *Context

+ func NewDockerContextByCfg(cfg DockerConfig) *Context

+ func NewKubernetesContext() *Context

+ func NewKubernetesContextByCfg(cfg KubernetesConfig) *Context

+ func NewProcessContext() *Context

+ func NewProcessContextByCfg(cfg ProcessConfig) *Context

+ func (c *Context) Error() error

+ func (c *Context) HasError() bool

+ func (c *Context) OnError(f func(e error)) *Context

+ type DockerConfig struct

+ DBFile string

+ DefaultDockerImage string

+ type Iterator func(drmaa2interface.JobTemplate) drmaa2interface.JobTemplate

+ func NewEnvSequenceIterator(env string, start, incr int) Iterator

+ func NewTimeIterator(d time.Duration) Iterator

+ type Job struct

+ func EmptyJob() *Job

+ func NewJob(wfl *Workflow) *Job

+ func (j *Job) After(d time.Duration) *Job

+ func (j *Job) AnyFailed() bool

+ func (j *Job) Do(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) ExitStatus() int

+ func (j *Job) Failed() bool

+ func (j *Job) HasAnyFailed() bool

+ func (j *Job) JobID() string

+ func (j *Job) JobInfo() drmaa2interface.JobInfo

+ func (j *Job) JobInfos() []drmaa2interface.JobInfo

+ func (j *Job) Kill() *Job

+ func (j *Job) LastError() error

+ func (j *Job) ListAllFailed() []drmaa2interface.Job

+ func (j *Job) Notify(n *Notifier) *Job

+ func (j *Job) Observe(o Observer) *Job

+ func (j *Job) OnError(f func(err error)) *Job

+ func (j *Job) OnFailure(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) OnFailureRun(cmd string, args ...string) *Job

+ func (j *Job) OnFailureRunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) OnSuccess(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) OnSuccessRun(cmd string, args ...string) *Job

+ func (j *Job) OnSuccessRunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) Resubmit(r int) *Job

+ func (j *Job) Resume() *Job

+ func (j *Job) Retry(r int) *Job

+ func (j *Job) RetryAnyFailed(amount int) *Job

+ func (j *Job) Run(cmd string, args ...string) *Job

+ func (j *Job) RunEvery(d time.Duration, end time.Time, cmd string, args ...string) error

+ func (j *Job) RunEveryT(d time.Duration, end time.Time, jt drmaa2interface.JobTemplate) error

+ func (j *Job) RunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) State() drmaa2interface.JobState

+ func (j *Job) Success() bool

+ func (j *Job) Suspend() *Job

+ func (j *Job) Synchronize() *Job

+ func (j *Job) Tag() string

+ func (j *Job) TagWith(tag string) *Job

+ func (j *Job) Template() *drmaa2interface.JobTemplate

+ func (j *Job) Then(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) ThenRun(cmd string, args ...string) *Job

+ func (j *Job) ThenRunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) Wait() *Job

+ type KubernetesConfig struct

+ DBFile string

+ DefaultImage string

+ type Notifier struct

+ func NewNotifier() *Notifier

+ func (n *Notifier) Destroy()

+ func (n *Notifier) ReceiveJob() *Job

+ func (n *Notifier) SendJob(job *Job)

+ type Observer struct

+ ErrorHandler func(error)

+ FailedHandler func(drmaa2interface.Job)

+ SuccessHandler func(drmaa2interface.Job)

+ func NewDefaultObserver() Observer

+ type ProcessConfig struct

+ DBFile string

+ type Template struct

+ Jt drmaa2interface.JobTemplate

+ func NewTemplate(jt drmaa2interface.JobTemplate) *Template

+ func (t *Template) AddIterator(name string, itr Iterator) *Template

+ func (t *Template) AddMap(name string, f Iterator) *Template

+ func (t *Template) MapTo(system string) drmaa2interface.JobTemplate

+ func (t *Template) Next() drmaa2interface.JobTemplate

+ func (t *Template) NextMap(name string) drmaa2interface.JobTemplate

+ type Workflow struct

+ func NewWorkflow(context *Context) *Workflow

+ func (w *Workflow) Error() error

+ func (w *Workflow) HasError() bool

+ func (w *Workflow) OnError(f func(e error)) *Workflow

+ func (w *Workflow) Run(cmd string, args ...string) *Job

+ func (w *Workflow) RunT(jt drmaa2interface.JobTemplate) *Job

Other modules containing this package

github.com/dgruber/wfl/v2

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