Skip to content

Commit fe6c254

Browse files
committed
infra updates
1 parent fec8ebc commit fe6c254

1 file changed

Lines changed: 1 addition & 17 deletions

File tree

retail-job/databricks.yml

Lines changed: 1 addition & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,6 @@ resources:
7474

7575
- task_key: "remove_duplicates_task"
7676
description: "Remove duplicate records from processed data"
77-
job_cluster_key: "main_cluster"
7877
notebook_task:
7978
notebook_path: "./Task Files/03_data_processing/remove_duplicates.py"
8079
source: WORKSPACE
@@ -84,7 +83,7 @@ resources:
8483
op: "EQUAL_TO"
8584
left: "{{tasks.join_customers_sales_task.values.has_duplicates}}"
8685
right: "true"
87-
86+
8887
- task_key: "transform_data_task"
8988
description: "Clean and transform data to gold layer"
9089
job_cluster_key: "main_cluster"
@@ -94,21 +93,6 @@ resources:
9493
depends_on:
9594
- task_key: "remove_duplicates_task"
9695
outcome: "true"
97-
98-
# - task_key: "process_state_data_task"
99-
# description: "Process orders data by state"
100-
# job_cluster_key: "main_cluster"
101-
# for_each_task:
102-
# inputs: '["CA", "NY", "TX", "FL"]'
103-
# task:
104-
# task_key: "process_single_state"
105-
# notebook_task:
106-
# notebook_path: "./Task Files/05_state_processing/process_orders_by_state.py"
107-
# source: WORKSPACE
108-
# base_parameters:
109-
# state: "{{item}}"
110-
# depends_on:
111-
# - task_key: "join_customers_orders_task"
11296

11397
- task_key: "process_state_data_task"
11498
description: "Process orders data by state"

0 commit comments

Comments
 (0)