savannahghi / sghi-etl-commons

100%

develop: 100%

LAST BUILD ON BRANCH feat-add-a-splitter-gather-processor

branch: feat-add-a-splitter-gather-processor

CHANGE BRANCH

x

Reset

• feat-add-a-splitter-gather-processor
• chore-delay-embedded-processors-disposal
• chore-delay-embedded-sinks-disposal
• chore-delay-embedded-sources-disposal
• chore-delay-embedded-sources-gathering
• chore-make-processor-of-callable-final
• chore-rename-sinks-source-of-callable
• chore-upgrade-deps
• ci-fix-tox-config
• ci-set-up-release-pipeline
• ci-update-ruff-config
• dependabot/npm_and_yarn/braces-3.0.3
• develop
• docs-add-examples-to-readme
• docs-fixes
• docs-imporove-readme
• docs-improve-docs
• docs-update-readme-badges
• feat-add-a-processor-decorator
• feat-add-a-scatter-gather-processor
• feat-add-a-sink-decorator
• feat-add-a-source-decorator
• feat-add-gather-source
• feat-add-noop-processor
• feat-add-null-sink
• feat-add-processor-pipe
• feat-add-prologue-and-epilogue-workflow-functions
• feat-add-retry-support-when-running-wfs
• feat-add-run-workflow-utility
• feat-add-scatter-sink
• feat-add-simple-workflow-def
• feat-add-split-sink
• feat-add-workflow-builder
• feat-support-running-workflow-instances-directly
• main
• next
• prototype

Build # 9007086744

Build Type

Pull #17

github

Committed by kennedykori

Commit Message

feat(processors): add a `SplitGatherProcessor`

Add `sghi.etl.commons.processors.SplitGatherProcessor`, a `Processor`
that splits aggregated raw data into its constituent data parts and then
processes each data part concurrently.

Pull Request Pull Request #17: feat(processors): add a `SplitGatherProcessor`

Run Details

255 of 255 branches covered (100.0%)

Branch coverage included in aggregate %.

53 of 53 new or added lines in 1 file covered. (100.0%)

409 of 409 relevant lines covered (100.0%)

1.0 hits per line