Package schedule contains implementations of ppacer Schedules.

Package tasklog implements ppacer Task loggers.

Default template for alerts.

New creates new Dag instance for given DAG identifier.

NewNode initialize Node with given task and returns the reference.

ParseRunStatus parses run status based on given string.

ParseTaskStatus parses task status based on given string.

TaskExecuteSource returns Task's source code of its Execute() method.

TaskHash returns SHA256 of given Task Execute method body source.

WithCustomFailureAlertTemplate returns TaskConfigFunc for setting a custom template for alerts in cases when Task execution has failed.

WithCustomNotifier returns TaskConfigFunc for setting a custom notification sender for the task.

WithCustomRetryAlertTemplate returns TaskConfigFunc for setting a custom template for alerts in cases when Task execution has failed and will be retried.

WithTaskNotSendAlertsOnFailures is a TaskConfigFunc which sets off sending alerts on task failure.

WithTaskRetries returns TaskConfigFunc for setting number of retries for task execution.

WithTaskRetriesDelay returns TaskConfigFunc for setting delay duration between next retries of task execution.

WithTaskSendAlertOnRetries is a TaskConfigFunc which sets sending alerts on task retries.

WithTaskTimeout returns TaskConfigFunc for setting a timeout for task execution.

Default task configuration.

Attr represents additional attributes and parameters about Dag and its scheduling.

Dag represents a single process that can be scheduled by ppacer.

Node represents single node (vertex) in the DAG.

NodeInfo represents enriched information about node in the DAG.

TODO.

TaskConfig represents Task configuration.

TaskContext is a context for Task execute method.

DAG run task information context.

Task represents single step in DAG which is going to be scheduled and executed via executors.

DAG string identifier.

Registry for DAGs.

RunStatus enumerates possible DAG run states.

TaskConfigFunc is a family of functions which takes a TaskConfig and potentially updates values of given configuration.

TaskStatus enumerates possible Task states within the DAG run.