Pipeline A reads the day's orders, groups by customer, and row-by-row INSERTs into a plain Snowflake

A medium Pipeline Design interview practice problem on DataDriven. Write and execute real pipeline design code with instant grading.

Domain

Pipeline Design

Difficulty

medium

Problem

Pipeline A reads the day's orders, groups by customer, and row-by-row INSERTs into a plain Snowflake daily_customer_summary. Each rerun multiplies the rows. The aggregation logic is correct; the bug lives entirely in the write semantics. Convert Pipeline A to Pipeline B by applying the section's named fix at the destination, leaving the aggregation untouched.

Practice This Problem

Solve this Pipeline Design problem with real code execution. DataDriven runs your solution and grades it automatically.