본문으로 건너뛰기
← Workshop overview
Chapter 3 of 7
15 min

Enrich inventory with the competitor price

Run the price-update pipeline and interpret the same row across two datasets and the complete output scope.

Question for this chapter

What does the pipeline change in an inventory row, and what does it preserve?

Why this matters now

The dashboard reads price-adjustment candidates from the enriched output. Without verifying the run, an old competitor price could be mistaken for a current observation.

Try it

Open Competitor Price Update under Pipelines and inspect the four connected nodes.

Pipeline connecting Product Information and Competitor Price Data to an output dataset
Verify the two inputs, price-update code, and output dataset.

Select the code node. It left-joins the two inputs on item_code and changes only competitor_price_krw_synth where an observation exists.

Configuration panel for the competitor-price update code node
Verify that the code node receives two inputs and creates the output.

Select Run now in the upper-right. When the run completes, open Data in Competitor Price Update Result and verify the 46,700-row count above the table. Return to the pipeline canvas and verify the orange replace icon on the rightmost output dataset node. Hovering over it shows Overwrite.

Competitor-price update pipeline in a running state
Check the run-start notification and running state.

Open Product Information, select SQL Scratch Pad, and run this query.

SELECT item_code, branch_name, inventory_qty,
       selling_price_krw_synth, competitor_price_krw_synth
FROM `retail_inventory_intelligence`.`retail_inventory`
WHERE item_code = 7224000894
  AND branch_code = 'GNM0'
  AND `PROD_GRP` = 'YT44402461'
LIMIT 1;

In Competitor Price Update Result, run the same query with the output table name.

SELECT item_code, branch_name, inventory_qty,
       selling_price_krw_synth, competitor_price_krw_synth
FROM `retail_inventory_intelligence`.`update_competitor_price`
WHERE item_code = 7224000894
  AND branch_code = 'GNM0'
  AND `PROD_GRP` = 'YT44402461'
LIMIT 1;

Results to verify

  • Above Competitor Price Update Result > Data: 46,700 rows
  • On the rightmost output dataset node: the orange replace icon (Overwrite)
FieldProduct InformationCompetitor Price Update ResultInterpretation
item_code72240008947224000894Same product
branch_nameGangnam Finance BranchGangnam Finance BranchBranch preserved
inventory_qty5151Inventory preserved
selling_price_krw_synthKRW 4,490KRW 4,490Selling price preserved
competitor_price_krw_synthKRW 4,500KRW 4,670Competitor price enriched

Interpret the result

The pipeline did not append 46,700 new facts. It preserved the original inventory-row structure while enriching the comparison field. Overwrite keeps the output as one current snapshot.

Version history shows version samples but does not provide row-level change summaries. For that reason, counts such as 46,444 changed rows and 256 unchanged rows are not used as success criteria.

Troubleshooting — if the run fails
  1. Verify that both input datasets have more than zero rows.
  2. Verify that price_krw is numeric rather than a string containing a currency symbol.
  3. Verify that the output has a new version and 46,700 rows.

Next decision

Price and inventory are now comparable in one row. Next, expand a product into its branch, region, and supplier relationships to identify the operational context for follow-up.