Skip to content

Commit 2e34289

Browse files
committed
fix: pass shared bundle vars to delta pipeline commands
1 parent 4e94401 commit 2e34289

4 files changed

Lines changed: 14 additions & 0 deletions

File tree

scripts/deploy-databricks-delta-pipeline.sh

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ source_id="${CONVEX_SOURCE_ID:-$deployment_url}"
4141
source_slug="${CONVEX_SYNC_SOURCE_SLUG:-default}"
4242
source_slug_sql="${CONVEX_SYNC_SOURCE_SQL:-${source_slug//-/_}}"
4343
deployment_slug="${DATABRICKS_DELTA_DEPLOYMENT_SLUG:-${source_slug}-${target}}"
44+
job_name="${DATABRICKS_DELTA_JOB_NAME:-convex-sync-kit-${deployment_slug}-delta-extract}"
4445
pipeline_name="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_NAME:-convex-sync-kit-${deployment_slug}-autocdc}"
4546
pipeline_file="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_FILE:-${deployment_slug}-bronze-to-silver.sql}"
4647
generated_file="$bundle_root/generated/$pipeline_file"
@@ -61,6 +62,7 @@ checkpoint_table="${DATABRICKS_DELTA_CHECKPOINT_TABLE:-connector_checkpoint}"
6162
bundle_args=(
6263
--var "convex_deployment_url=$deployment_url"
6364
--var "source_slug=$source_slug"
65+
--var "job_name=$job_name"
6466
--var "convex_deploy_key_secret_scope=$secret_scope"
6567
--var "convex_deploy_key_secret_key=$secret_key"
6668
--var "source_id=$source_id"

scripts/deploy-databricks-delta.sh

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,8 @@ catalog="${DATABRICKS_DELTA_CATALOG:-workspace}"
4949
control_schema="${DATABRICKS_DELTA_CONTROL_SCHEMA:-convex_sync_kit_${source_slug_sql}_delta_control}"
5050
bronze_schema="${DATABRICKS_DELTA_BRONZE_SCHEMA:-convex_sync_kit_${source_slug_sql}_delta_bronze}"
5151
checkpoint_table="${DATABRICKS_DELTA_CHECKPOINT_TABLE:-connector_checkpoint}"
52+
pipeline_name="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_NAME:-convex-sync-kit-${deployment_slug}-autocdc}"
53+
pipeline_file="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_FILE:-${deployment_slug}-bronze-to-silver.sql}"
5254

5355
"$repo_root/scripts/ensure-databricks-delta-secret.sh" "$profile" "$secret_scope" "$secret_key"
5456

@@ -64,7 +66,10 @@ bundle_args=(
6466
--var "catalog=$catalog"
6567
--var "control_schema=$control_schema"
6668
--var "bronze_schema=$bronze_schema"
69+
--var "silver_schema=$silver_schema"
6770
--var "checkpoint_table=$checkpoint_table"
71+
--var "autocdc_pipeline_name=$pipeline_name"
72+
--var "autocdc_pipeline_file=$pipeline_file"
6873
)
6974

7075
(

scripts/run-databricks-delta-job.sh

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,8 @@ catalog="${DATABRICKS_DELTA_CATALOG:-workspace}"
5050
control_schema="${DATABRICKS_DELTA_CONTROL_SCHEMA:-convex_sync_kit_${source_slug_sql}_delta_control}"
5151
bronze_schema="${DATABRICKS_DELTA_BRONZE_SCHEMA:-convex_sync_kit_${source_slug_sql}_delta_bronze}"
5252
checkpoint_table="${DATABRICKS_DELTA_CHECKPOINT_TABLE:-connector_checkpoint}"
53+
pipeline_name="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_NAME:-convex-sync-kit-${deployment_slug}-autocdc}"
54+
pipeline_file="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_FILE:-${deployment_slug}-bronze-to-silver.sql}"
5355

5456
"$repo_root/scripts/ensure-databricks-delta-secret.sh" "$profile" "$secret_scope" "$secret_key"
5557

@@ -65,7 +67,10 @@ bundle_args=(
6567
--var "catalog=$catalog"
6668
--var "control_schema=$control_schema"
6769
--var "bronze_schema=$bronze_schema"
70+
--var "silver_schema=$silver_schema"
6871
--var "checkpoint_table=$checkpoint_table"
72+
--var "autocdc_pipeline_name=$pipeline_name"
73+
--var "autocdc_pipeline_file=$pipeline_file"
6974
)
7075

7176
(

scripts/run-databricks-delta-pipeline.sh

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ source_id="${CONVEX_SOURCE_ID:-$deployment_url}"
4141
source_slug="${CONVEX_SYNC_SOURCE_SLUG:-default}"
4242
source_slug_sql="${CONVEX_SYNC_SOURCE_SQL:-${source_slug//-/_}}"
4343
deployment_slug="${DATABRICKS_DELTA_DEPLOYMENT_SLUG:-${source_slug}-${target}}"
44+
job_name="${DATABRICKS_DELTA_JOB_NAME:-convex-sync-kit-${deployment_slug}-delta-extract}"
4445
pipeline_name="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_NAME:-convex-sync-kit-${deployment_slug}-autocdc}"
4546
pipeline_file="${DATABRICKS_DELTA_AUTOCDC_PIPELINE_FILE:-${deployment_slug}-bronze-to-silver.sql}"
4647
generated_file="$bundle_root/generated/$pipeline_file"
@@ -61,6 +62,7 @@ checkpoint_table="${DATABRICKS_DELTA_CHECKPOINT_TABLE:-connector_checkpoint}"
6162
bundle_args=(
6263
--var "convex_deployment_url=$deployment_url"
6364
--var "source_slug=$source_slug"
65+
--var "job_name=$job_name"
6466
--var "convex_deploy_key_secret_scope=$secret_scope"
6567
--var "convex_deploy_key_secret_key=$secret_key"
6668
--var "source_id=$source_id"

0 commit comments

Comments
 (0)