Function runPipelineChain

coinmetrics/utils/pipelines.py:151–177 · view source on GitHub ↗

(tasks, pipelines, log, eta=None, taskRepr=None, prefetchCount=1)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

nothing calls this directly

getCountMethod · 0.95

runMethod · 0.95

allDoneMethod · 0.95

interruptedMethod · 0.95

ExecutionCounterClass · 0.85

EtaOutputClass · 0.85

TaskSpawnerClass · 0.85

reportPipelineExceptionsFunction · 0.85

anyPipelineFaultedFunction · 0.85

shutdownMethod · 0.80

no test coverage detected