{
  "code": null,
  "collection": "architecture",
  "href": "https://banes-lab.com/ontology#architecture-pipeline-architecture",
  "id": "pipeline-architecture",
  "kind": "pattern",
  "layer": {
    "href": "https://banes-lab.com/ontology/schema#layer-execution-core",
    "json": "https://banes-lab.com/json/records/layer/execution-core",
    "label": "Execution Core",
    "markdown": "https://banes-lab.com/records/layer/execution-core.md",
    "ref": "layer:execution-core"
  },
  "name": "Pipeline Architecture",
  "ref": "architecture:pipeline-architecture",
  "relations": [
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-stage-contracts",
          "json": "https://banes-lab.com/json/records/lexicon/stage-contracts",
          "label": "Stage Contracts",
          "markdown": "https://banes-lab.com/records/lexicon/stage-contracts.md",
          "ref": "lexicon:stage-contracts"
        }
      ],
      "relation": "requires"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-composability",
          "json": "https://banes-lab.com/json/records/architecture/composability",
          "label": "Composability",
          "markdown": "https://banes-lab.com/records/architecture/composability.md",
          "ref": "architecture:composability"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-streaming",
          "json": "https://banes-lab.com/json/records/lexicon/streaming",
          "label": "Streaming",
          "markdown": "https://banes-lab.com/records/lexicon/streaming.md",
          "ref": "lexicon:streaming"
        }
      ],
      "relation": "reinforces"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-stepwise-transformation",
          "json": "https://banes-lab.com/json/records/lexicon/stepwise-transformation",
          "label": "Stepwise Transformation",
          "markdown": "https://banes-lab.com/records/lexicon/stepwise-transformation.md",
          "ref": "lexicon:stepwise-transformation"
        }
      ],
      "relation": "enables"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-monolithic-processing-function",
          "json": "https://banes-lab.com/json/records/lexicon/monolithic-processing-function",
          "label": "Monolithic Processing Function",
          "markdown": "https://banes-lab.com/records/lexicon/monolithic-processing-function.md",
          "ref": "lexicon:monolithic-processing-function"
        }
      ],
      "relation": "conflicts-with"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-error-propagation-debugging",
          "json": "https://banes-lab.com/json/records/lexicon/error-propagation-debugging",
          "label": "Error Propagation/Debugging",
          "markdown": "https://banes-lab.com/records/lexicon/error-propagation-debugging.md",
          "ref": "lexicon:error-propagation-debugging"
        }
      ],
      "relation": "tensions-with"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/schema#tension-error-propagation-debugging-pipeline-architecture",
          "json": "https://banes-lab.com/json/records/tension/error-propagation-debugging-pipeline-architecture",
          "label": "Pipeline Architecture / Error Propagation/Debugging",
          "markdown": "https://banes-lab.com/records/tension/error-propagation-debugging-pipeline-architecture.md",
          "ref": "tension:error-propagation-debugging-pipeline-architecture"
        }
      ],
      "relation": "tensions"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-monolithic-processing-function",
          "json": "https://banes-lab.com/json/records/lexicon/monolithic-processing-function",
          "label": "Monolithic Processing Function",
          "markdown": "https://banes-lab.com/records/lexicon/monolithic-processing-function.md",
          "ref": "lexicon:monolithic-processing-function"
        }
      ],
      "relation": "violated-by"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-define-contract",
          "json": "https://banes-lab.com/json/records/lexicon/define-contract",
          "label": "Define Contract",
          "markdown": "https://banes-lab.com/records/lexicon/define-contract.md",
          "ref": "lexicon:define-contract"
        }
      ],
      "relation": "refactored-by"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/schema#vocabulary-severity-recommended",
          "json": "https://banes-lab.com/json/records/vocabulary/severity-recommended",
          "label": "recommended",
          "markdown": "https://banes-lab.com/records/vocabulary/severity-recommended.md",
          "ref": "vocabulary:severity-recommended"
        }
      ],
      "relation": "severity"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-category-streaming-pipeline-dataflow-processing",
          "json": "https://banes-lab.com/json/records/architecture-category/streaming-pipeline-dataflow-processing",
          "label": "Streaming / Pipeline / Dataflow Processing",
          "markdown": "https://banes-lab.com/records/architecture-category/streaming-pipeline-dataflow-processing.md",
          "ref": "architecture-category:streaming-pipeline-dataflow-processing"
        }
      ],
      "relation": "category"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-dataflow-architecture",
          "json": "https://banes-lab.com/json/records/architecture/dataflow-architecture",
          "label": "Dataflow Architecture",
          "markdown": "https://banes-lab.com/records/architecture/dataflow-architecture.md",
          "ref": "architecture:dataflow-architecture"
        }
      ],
      "relation": "reinforced-by"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-dataflow-architecture",
          "json": "https://banes-lab.com/json/records/architecture/dataflow-architecture",
          "label": "Dataflow Architecture",
          "markdown": "https://banes-lab.com/records/architecture/dataflow-architecture.md",
          "ref": "architecture:dataflow-architecture"
        },
        {
          "href": "https://banes-lab.com/ontology#architecture-pipes-and-filters",
          "json": "https://banes-lab.com/json/records/architecture/pipes-and-filters",
          "label": "Pipes and Filters",
          "markdown": "https://banes-lab.com/records/architecture/pipes-and-filters.md",
          "ref": "architecture:pipes-and-filters"
        }
      ],
      "relation": "refactors"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/disciplined-methodology/ship#one-chain",
          "json": "https://banes-lab.com/json/disciplined-methodology/ship/one-chain",
          "label": "One chain",
          "markdown": "https://banes-lab.com/disciplined-methodology/ship/one-chain.md",
          "ref": "chapter:/disciplined-methodology/ship#one-chain"
        },
        {
          "href": "https://banes-lab.com/ontology#architecture-category-core-modular-design",
          "json": "https://banes-lab.com/json/ontology/principles/architecture-category-core-modular-design",
          "label": "Core Modular Design",
          "markdown": "https://banes-lab.com/ontology/principles/architecture-category-core-modular-design.md",
          "ref": "chapter:/ontology#architecture-category-core-modular-design"
        },
        {
          "href": "https://banes-lab.com/ontology#architecture-category-streaming-pipeline-dataflow-processing",
          "json": "https://banes-lab.com/json/ontology/principles/architecture-category-streaming-pipeline-dataflow-processing",
          "label": "Streaming / Pipeline / Dataflow Processing",
          "markdown": "https://banes-lab.com/ontology/principles/architecture-category-streaming-pipeline-dataflow-processing.md",
          "ref": "chapter:/ontology#architecture-category-streaming-pipeline-dataflow-processing"
        },
        {
          "href": "https://banes-lab.com/ontology#architecture-category-codebase-system-architecture-styles",
          "json": "https://banes-lab.com/json/ontology/principles/architecture-category-codebase-system-architecture-styles",
          "label": "Codebase / System Architecture Styles",
          "markdown": "https://banes-lab.com/ontology/principles/architecture-category-codebase-system-architecture-styles.md",
          "ref": "chapter:/ontology#architecture-category-codebase-system-architecture-styles"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-category-contracts-interfaces-compatibility",
          "json": "https://banes-lab.com/json/ontology/lexicon/lexicon-category-contracts-interfaces-compatibility",
          "label": "Contracts / Interfaces / Compatibility",
          "markdown": "https://banes-lab.com/ontology/lexicon/lexicon-category-contracts-interfaces-compatibility.md",
          "ref": "chapter:/ontology/lexicon#lexicon-category-contracts-interfaces-compatibility"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-category-streaming-pipeline-dataflow-processing",
          "json": "https://banes-lab.com/json/ontology/lexicon/lexicon-category-streaming-pipeline-dataflow-processing",
          "label": "Streaming / Pipeline / Dataflow Processing",
          "markdown": "https://banes-lab.com/ontology/lexicon/lexicon-category-streaming-pipeline-dataflow-processing.md",
          "ref": "chapter:/ontology/lexicon#lexicon-category-streaming-pipeline-dataflow-processing"
        },
        {
          "href": "https://banes-lab.com/ontology/schema#the-vocabulary-severity",
          "json": "https://banes-lab.com/json/ontology/schema/the-vocabulary-severity",
          "label": "Severity levels",
          "markdown": "https://banes-lab.com/ontology/schema/the-vocabulary-severity.md",
          "ref": "chapter:/ontology/schema#the-vocabulary-severity"
        },
        {
          "href": "https://banes-lab.com/ontology/schema#the-resolutions",
          "json": "https://banes-lab.com/json/ontology/schema/the-resolutions",
          "label": "The resolutions",
          "markdown": "https://banes-lab.com/ontology/schema/the-resolutions.md",
          "ref": "chapter:/ontology/schema#the-resolutions"
        }
      ],
      "relation": "linked-from"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/anatomy/pipeline#file-pipeline-core-factories-plan-factory-ts",
          "json": "https://banes-lab.com/json/source/pipeline/core/factories/plan.factory.ts",
          "label": "stagesFor",
          "markdown": "https://banes-lab.com/source/pipeline/core/factories/plan.factory.ts.md",
          "ref": "anatomy:file-pipeline-core-factories-plan-factory-ts"
        },
        {
          "href": "https://banes-lab.com/anatomy/pipeline#file-pipeline-core-coordinators-stage-coordinator-ts",
          "json": "https://banes-lab.com/json/source/pipeline/core/coordinators/stage.coordinator.ts",
          "label": "runStages",
          "markdown": "https://banes-lab.com/source/pipeline/core/coordinators/stage.coordinator.ts.md",
          "ref": "anatomy:file-pipeline-core-coordinators-stage-coordinator-ts"
        }
      ],
      "relation": "evidence"
    }
  ],
  "summary": "A design pattern that splits processing into ordered stages, each with a declared input and output contract.",
  "siblings": {
    "next": {
      "href": "https://banes-lab.com/ontology#architecture-lazy-evaluation",
      "json": "https://banes-lab.com/json/records/architecture/lazy-evaluation",
      "label": "Lazy Evaluation",
      "markdown": "https://banes-lab.com/records/architecture/lazy-evaluation.md",
      "ref": "architecture:lazy-evaluation"
    },
    "previous": {
      "href": "https://banes-lab.com/ontology#architecture-single-pass-processing",
      "json": "https://banes-lab.com/json/records/architecture/single-pass-processing",
      "label": "Single-Pass Processing",
      "markdown": "https://banes-lab.com/records/architecture/single-pass-processing.md",
      "ref": "architecture:single-pass-processing"
    }
  },
  "up": {
    "href": null,
    "json": "https://banes-lab.com/json/api/records/architecture",
    "label": "Architecture principles",
    "markdown": "https://banes-lab.com/api/records/architecture.md",
    "ref": "api:records/architecture"
  },
  "aliases": [],
  "exemplar": {
    "after": "const fooPipeline = pipeline(\n  parseJson,\n  validateWith(FooSchema),\n  normalizeFoo,\n  saveFoo,\n);\nfooPipeline.run(raw);",
    "before": "function processFoo(raw: string) {\n  const parsed = JSON.parse(raw);\n  const validated = validateFoo(parsed);\n  const normalized = normalizeFoo(validated);\n  return saveFoo(normalized);\n}",
    "lang": "ts",
    "medium": "code"
  },
  "formedBy": null,
  "scope": [
    "processing",
    "dataflow",
    "build"
  ],
  "severity": "recommended"
}