ToDecimal converts an input to a decimal.

RunStatusCompleted is used for when a run has successfully completed execution.

RunStatusErrored is used for when a run has errored and will not complete.

RunStatusRunning is used for when a run is actively being executed.

RunStatusSuspended is used when a run is paused and awaiting further results.

RunStatusUnknown is the when the run status cannot be determined.

Testing only.

AnyTask picks a value at random from the set of non-errored inputs.

Return types: *decimal.Decimal .

When a task panics, we catch the panic and wrap it in an error for reporting to the scheduler.

Return types: map[string]interface{} with any geth/abigen value type .

Return types: map[string]interface{} with any geth/abigen value type .

Return types: []byte .

Return types: []byte .

FailTask is like the Panic task but without all the drama and stack unwinding of a panic.

FinalResult is the result of a Run.

tree fulfills the graph.DirectedGraph interface, which makes it possible for us to `dot.Unmarshal(...)` a DOT string directly into it.

HTTPRequest holds the request and config struct for a http request.

Return types: string .

Return types: float64 string bool map[string]interface{} []interface{} nil .

Return types: string .

Return types: *decimal.Decimal .

Return types: *decimal.Decimal .

Return types: map[string]interface{} .

go-ethereum's abi.Method doesn't implement json.Marshal for Type, but otherwise would have worked fine, in any case we only care about these...

Return types: map[string]interface{}{ "results": []interface{} containing any other type other pipeline tasks can return "occurrences": (int64) } .

Return types: *decimal.Decimal .

ObjectParam represents a kind of any type that could be used by the memo task.

Result is the result of a TaskRun.

RunInfo contains additional information about the finished TaskRun.

Return types: *decimal.Decimal .

Wraps the input Task for the given dependent task along with a bool variable PropagateResult, which Indicates whether result of InputTask should be propagated to its dependent task.

TaskRunResult describes the result of a task run, suitable for database update or insert.

Return types: string .

MapParam accepts maps or JSON-encoded strings.

RunStatus represents the status of a run.

TaskRunResults represents a collection of results for all task runs for one pipeline run.