# pipedreamhq/pipedream architecture

> Architecture diagram of the GitHub repository pipedreamhq/pipedream, generated by GitDiagram from its file tree, README and a sample of source files (last updated 2026-09-29). It is an AI-made overview: check details against the source.

- Interactive diagram: https://gitdiagram.com/pipedreamhq/pipedream
- Repository: https://github.com/pipedreamhq/pipedream

## Overview

Pipedream is a developer integration platform for event-driven automations. Its documented workflow begins with an event source, runs a sequence of prebuilt actions or custom code, and may deliver events asynchronously to destinations. This repository primarily contains the prebuilt integration components; the README describes platform-level workflow behavior that is not represented by a sampled workflow engine here. The graph preserves major integration families and central modules named in the source index. Unsampled implementation details are omitted; documented relationships cite the README.

Main entry points: [`components`](https://github.com/pipedreamhq/pipedream/tree/master/components) (Workflows), [`components/database/actions/query-sql-database/query-sql-database.mjs`](https://github.com/pipedreamhq/pipedream/blob/master/components/database/actions/query-sql-database/query-sql-database.mjs) (SQL query action), [`components/bitbucket`](https://github.com/pipedreamhq/pipedream/tree/master/components/bitbucket) (Bitbucket events), [`components/oracle_cloud_infrastructure/sources/common/webhook.mjs`](https://github.com/pipedreamhq/pipedream/blob/master/components/oracle_cloud_infrastructure/sources/common/webhook.mjs) (OCI storage events)

## Diagram (Mermaid)

```mermaid
flowchart TD

subgraph group_automation["Automation capabilities"]
  node_workflow["Workflows"]
  node_custom["Custom code"]
  node_destinations["Destinations"]
end

subgraph group_triggers["Event sources"]
  node_sources["Event sources"]
  node_bitbucket["Bitbucket events"]
  node_oci["OCI storage events<br/>[webhook.mjs]"]
end

subgraph group_integrations["App integrations"]
  node_hubspot["HubSpot CRM<br/>[hubspot.app.mjs]"]
  node_trustpilot["Trustpilot reviews<br/>[trustpilot.app.mjs]"]
  node_azurepipelines["Azure pipelines"]
  node_pagerduty["PagerDuty<br/>[pagerduty.app.mjs]"]
  node_salesflare["Salesflare CRM<br/>[salesflare.app.mjs]"]
end

subgraph group_data["Data and pipelines"]
  node_sqlaction["SQL query action"]
  node_sqladapters["SQL adapters"]
  node_notion["Notion queries<br/>[query-database.mjs]"]
  node_aws["AWS Redshift"]
  node_pipelineapp["Pipeline app<br/>[pipeline.app.mjs]"]
end

node_developer(("Developer"))

node_developer -->|"configures"| node_workflow
node_sources -->|"triggers"| node_workflow
node_workflow -->|"runs steps"| node_custom
node_workflow -->|"delivers events"| node_destinations
node_bitbucket -->|"emits events"| node_sources
node_oci -->|"emits events"| node_sources
node_workflow -->|"uses actions"| node_hubspot
node_workflow -->|"uses actions"| node_trustpilot
node_workflow -->|"uses actions"| node_azurepipelines
node_workflow -->|"uses actions"| node_pagerduty
node_workflow -->|"uses actions"| node_salesflare
node_workflow -->|"uses actions"| node_sqlaction
node_sqlaction -->|"dispatches"| node_sqladapters
node_workflow -->|"uses actions"| node_notion
node_workflow -->|"uses actions"| node_aws
node_workflow -->|"uses actions"| node_pipelineapp

click node_workflow "https://github.com/pipedreamhq/pipedream/tree/master/components"
click node_custom "https://github.com/pipedreamhq/pipedream/tree/master/components"
click node_destinations "https://github.com/pipedreamhq/pipedream/tree/master/components"
click node_sources "https://github.com/pipedreamhq/pipedream/tree/master/components"
click node_bitbucket "https://github.com/pipedreamhq/pipedream/tree/master/components/bitbucket"
click node_oci "https://github.com/pipedreamhq/pipedream/blob/master/components/oracle_cloud_infrastructure/sources/common/webhook.mjs"
click node_hubspot "https://github.com/pipedreamhq/pipedream/blob/master/components/hubspot/hubspot.app.mjs"
click node_trustpilot "https://github.com/pipedreamhq/pipedream/blob/master/components/trustpilot/trustpilot.app.mjs"
click node_azurepipelines "https://github.com/pipedreamhq/pipedream/blob/master/components/azure_devops/azure_devops.app.mjs"
click node_pagerduty "https://github.com/pipedreamhq/pipedream/blob/master/components/pagerduty/pagerduty.app.mjs"
click node_salesflare "https://github.com/pipedreamhq/pipedream/blob/master/components/salesflare/salesflare.app.mjs"
click node_sqlaction "https://github.com/pipedreamhq/pipedream/blob/master/components/database/actions/query-sql-database/query-sql-database.mjs"
click node_sqladapters "https://github.com/pipedreamhq/pipedream/tree/master/components/postgresql"
click node_notion "https://github.com/pipedreamhq/pipedream/blob/master/components/notion/actions/query-database/query-database.mjs"
click node_aws "https://github.com/pipedreamhq/pipedream/blob/master/components/aws/actions/redshift-query-database/redshift-query-database.mjs"
click node_pipelineapp "https://github.com/pipedreamhq/pipedream/blob/master/components/pipeline/pipeline.app.mjs"

classDef toneNeutral fill:#f8fafc,stroke:#334155,stroke-width:1.5px,color:#0f172a
classDef toneBlue fill:#dbeafe,stroke:#2563eb,stroke-width:1.5px,color:#172554
classDef toneAmber fill:#fef3c7,stroke:#d97706,stroke-width:1.5px,color:#78350f
classDef toneMint fill:#dcfce7,stroke:#16a34a,stroke-width:1.5px,color:#14532d
classDef toneRose fill:#ffe4e6,stroke:#e11d48,stroke-width:1.5px,color:#881337
classDef toneIndigo fill:#e0e7ff,stroke:#4f46e5,stroke-width:1.5px,color:#312e81
classDef toneTeal fill:#ccfbf1,stroke:#0f766e,stroke-width:1.5px,color:#134e4a
class node_workflow,node_custom,node_destinations toneBlue
class node_sources,node_bitbucket,node_oci toneAmber
class node_hubspot,node_trustpilot,node_azurepipelines,node_pagerduty,node_salesflare toneMint
class node_sqlaction,node_sqladapters,node_notion,node_aws,node_pipelineapp toneRose
class node_developer toneIndigo
```

## Components

### Automation capabilities

- [Workflows](https://github.com/pipedreamhq/pipedream/tree/master/components): `components`
- [Custom code](https://github.com/pipedreamhq/pipedream/tree/master/components): `components`
- [Destinations](https://github.com/pipedreamhq/pipedream/tree/master/components): `components`

### Event sources

- [Event sources](https://github.com/pipedreamhq/pipedream/tree/master/components): `components`
- [Bitbucket events](https://github.com/pipedreamhq/pipedream/tree/master/components/bitbucket): `components/bitbucket`
- [OCI storage events](https://github.com/pipedreamhq/pipedream/blob/master/components/oracle_cloud_infrastructure/sources/common/webhook.mjs): `components/oracle_cloud_infrastructure/sources/common/webhook.mjs`

### App integrations

- [HubSpot CRM](https://github.com/pipedreamhq/pipedream/blob/master/components/hubspot/hubspot.app.mjs): `components/hubspot/hubspot.app.mjs`
- [Trustpilot reviews](https://github.com/pipedreamhq/pipedream/blob/master/components/trustpilot/trustpilot.app.mjs): `components/trustpilot/trustpilot.app.mjs`
- [Azure pipelines](https://github.com/pipedreamhq/pipedream/blob/master/components/azure_devops/azure_devops.app.mjs): `components/azure_devops/azure_devops.app.mjs`
- [PagerDuty](https://github.com/pipedreamhq/pipedream/blob/master/components/pagerduty/pagerduty.app.mjs): `components/pagerduty/pagerduty.app.mjs`
- [Salesflare CRM](https://github.com/pipedreamhq/pipedream/blob/master/components/salesflare/salesflare.app.mjs): `components/salesflare/salesflare.app.mjs`

### Data and pipelines

- [SQL query action](https://github.com/pipedreamhq/pipedream/blob/master/components/database/actions/query-sql-database/query-sql-database.mjs): `components/database/actions/query-sql-database/query-sql-database.mjs`
- [SQL adapters](https://github.com/pipedreamhq/pipedream/tree/master/components/postgresql): `components/postgresql`
- [Notion queries](https://github.com/pipedreamhq/pipedream/blob/master/components/notion/actions/query-database/query-database.mjs): `components/notion/actions/query-database/query-database.mjs`
- [AWS Redshift](https://github.com/pipedreamhq/pipedream/blob/master/components/aws/actions/redshift-query-database/redshift-query-database.mjs): `components/aws/actions/redshift-query-database/redshift-query-database.mjs`
- [Pipeline app](https://github.com/pipedreamhq/pipedream/blob/master/components/pipeline/pipeline.app.mjs): `components/pipeline/pipeline.app.mjs`

### Other components

- **Developer**

## Connections

- Developer → Workflows: configures (evidence: `README.md`)
- Event sources → Workflows: triggers (evidence: `README.md`)
- Workflows → Custom code: runs steps (evidence: `README.md`)
- Workflows → Destinations: delivers events (evidence: `README.md`)
- Bitbucket events → Event sources: emits events (evidence: `README.md`)
- OCI storage events → Event sources: emits events (evidence: `README.md`)
- Workflows → HubSpot CRM: uses actions (evidence: `README.md`)
- Workflows → Trustpilot reviews: uses actions (evidence: `README.md`)
- Workflows → Azure pipelines: uses actions (evidence: `README.md`)
- Workflows → PagerDuty: uses actions (evidence: `README.md`)
- Workflows → Salesflare CRM: uses actions (evidence: `README.md`)
- Workflows → SQL query action: uses actions (evidence: `README.md`)
- SQL query action → SQL adapters: dispatches (evidence: `components/database/actions/query-sql-database/query-sql-database.mjs`)
- Workflows → Notion queries: uses actions (evidence: `README.md`)
- Workflows → AWS Redshift: uses actions (evidence: `README.md`)
- Workflows → Pipeline app: uses actions (evidence: `README.md`)