# dashbitco/flow

Computational parallel flows on top of GenStage

Repository: https://github.com/dashbitco/flow
Canonical: https://ross.abutalabs.com/products/dashbitco-flow
Homepage: https://hexdocs.pm/flow
Language: Elixir
License Family: other
Last push: 2026-08-18T17:08:45+00:00

## Health v2 (maintenance only)
Score: 76/100 (v2, computed 2026-09-03T02:20:16.233290+00:00)
- activity 98, release rhythm 35, longevity 100
- inputs: {"age_days": 3515, "days_push": 15, "days_rel": null, "gap_med": null, "n_releases_24m": 0}
- flags: no_releases, no_license
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 1621, forks 90 (observed 2026-08-28T04:05:12.523607+00:00)

## What it is
Flow is an Elixir library for expressing parallel computations on collections, built on top of GenStage. It provides an Enum/Stream-like API where map, filter, and reduce operations run concurrently across multiple processes.

## Use cases
- count word frequencies in a large file in parallel
- process large collections with map/reduce across multiple CPU cores
- build concurrent data processing pipelines in Elixir
- parallelize ETL-style transformations of enumerable data
- run stateful reductions partitioned across GenStage workers

## When to choose
- you need Enum/Stream-style computations parallelized in Elixir
- your workload fits in memory or streams from a source and benefits from multi-core processing
- you want backpressure-aware pipelines via GenStage

## When to avoid
- you need distributed processing across a cluster like Spark or Flink
- your data volume requires disk-based shuffling or fault-tolerant batch jobs
- you are not on the Erlang/Elixir ecosystem

## Facets
- artifact type: library
- maturity: maintenance
- function: streaming, concurrency, etl
- domain: microservices, developer-tools
- platform: elixir
- tags: elixir, genstage, parallel-computation, data-pipelines, data-engineering, erlang-vm

## Member repositories
- dashbitco/flow (main) score 76

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:05:12.523607+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-30T03:49:13.646726+00:00, confidence not recorded.
  - readme: https://github.com/dashbitco/flow (fetched 2026-08-28T04:05:12.523607+00:00, sha 6edf53354322)
  - homepage: https://hexdocs.pm/flow (fetched 2026-08-29T11:21:42.111418+00:00, sha 7d985a93ce2c)
- Data as of 2026-08-30T08:39:29.467469+00:00.