Sensyze
Currently viewing: Enterprise (Visual Designer) Open Source
• Coming soon
S
Account

Sensyze DataFlow

Multi-source · Daily · 6 nodes

READY
Step 0 of 6
Start by adding a source
Your pipeline canvas Click "Add Source" to begin building your pipeline 6 nodes · Multi-source · Daily sync ️ SHOPIFY API REST · orders, customers order_idstring total_pricenumber created_atdatetime OUTPUT ALL 📋 DATA PREVIEW
🗄️ DATA PREVIEW
0 IN → 3 OUT
INPUT DATA
OUTPUT DATA
ID DATA
id_sample_1 data_value_1
id_sample_2 data_value_2
id_sample_3 data_value_3
🗄️ POSTGRESQL DB · inventory, products product_iduuid stock_qtyinteger warehouse_idstring OUTPUT ALL 📋 DATA PREVIEW0 IN → 0 OUT ▾ 🔄 DBT: JOIN ORDERS SQL · aggregate, join REFINE_SUB_LOGIC INPUT RECORD 📋 DATA PREVIEW0 IN → 0 OUT ▾ 🐍 PYTHON: CLEAN normalize, validate def process(record): return normalize(record) DATA PREVIEW0 IN → 0 OUT ✨ PYTHON: ENRICH API · currency, geo def enrich(record): record.fx = fetch_fx(...) 📋 DATA PREVIEW0 IN → 0 OUT ▾ 🛡️ DATA MASKING compliance, pii modeANONYMISE columns masked3 🛡️ RULES: 3
🗄️ DATA PREVIEW
0 IN → 3 OUT
INPUT DATA
OUTPUT DATA
ID DATA
id_sample_1 data_value_1
id_sample_2 data_value_2
id_sample_3 data_value_3
💾 TARGET: POSTGRES analytics.orders_enriched INPUT RECORD 📋 DATA PREVIEW0 IN → 0 OUT + ADD SOURCE Click to browse catalog

Jobs & Schedules

Manage pipeline execution schedules and monitor job history

📅 Schedule Configuration

0 2 * * *
Runs daily at 02:00 UTC · Next run in 6h 23m
Run ID Status Started Duration Rows Action
a7f3d2e1-4b5c Success 2026-06-14 02:00:01 4m 32s 45,230
b8e4c3f2-5d6e Success 2026-06-13 02:00:03 4m 18s 43,891
c9f5d4g3-6e7f Scheduled 2026-06-15 02:00:00 — —

pipeline-e4d90ee5-a692fbe2

Failed
UTC v
History 44
Workers 1
Pending Activities 0
Stack Trace
Queries
Summary
Relationships
0 Parents 0 Pending Children 0 Children 0 First 0 Previous 0 Next
Input and Results
Input 3
{
  "debug_messages": [
    "=== PIPELINE CONFIG DEBUG ===",
    "Total Nodes: 6",
    "Node report:GET_MERCHANT_LISTINGS_ALL_DATA:
    {\"type\":\"schema\",\"schemaType\":\"source\",\"entityId\":\"report:GET_MERCHANT_LISTINGS_ALL_DATA\",\"hasContent\":false,\"contentLength\":0,\"hasMockData\":false,\"hasLastRunOutput\":false,\"fields\":25}",
    "Node report:GET_AMAZON_FULFILLED_SHIPMENTS_DATA:
    {\"type\":\"schema\",\"schemaType\":\"source\",\"entityId\":\"report:GET_AMAZON_FULFILLED_SHIPMENTS_DATA\",\"hasContent\":false,\"hasMockData\":false,\"hasLastRunOutput\":false,\"fields\":33}"
  ]
}
Results
{
  "type": "WorkflowExecutionFailedEventAttributes",
  "failure": {
    "message": "Activity task failed",
    "source": "",
    "stackTrace": "",
    "encodedAttributes": null,
    "cause": {
      "message": "Transformation Error: Column missing - 'None of [Index(['rgafsd_currency', 'rgafsd_item-price'], dtype='str')] are in the [columns]'",
      "source": "",
      "stackTrace": "  File \"/usr/local/lib/python3.11/site-packages/temporalio/worker/_activity.py\", line 359, in _handle_start_activity_task\n    result = await self._execute_activity()\n..."
    }
  }
}
Timeline

Event History

100
1-44 of 44
Date & Time v Workflow Events ≡ Expand All v
Welcome

Press Play to start the tour.

Builder
Jobs
Observability
Sources
Vault
Settings