Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sync jobs lowercase on snowflake

This commit is contained in:
dal 2025-04-28 14:21:43 -06:00
parent 679e46b535
commit 76da3b52be
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
api/libs/stored_values/src/jobs.rs
View File

@ -115,10 +115,10 @@ pub async fn sync_distinct_values_chunk(
.context("Failed to get DB connection for finding job ID")?;
stored_values_sync_jobs::table
.filter(stored_values_sync_jobs::data_source_id.eq(data_source_id))
.filter(stored_values_sync_jobs::database_name.eq(&database_name))
.filter(stored_values_sync_jobs::schema_name.eq(&schema_name))
.filter(stored_values_sync_jobs::table_name.eq(&table_name))
.filter(stored_values_sync_jobs::column_name.eq(&column_name))
.filter(stored_values_sync_jobs::database_name.eq(&database_name.to_lowercase()))
.filter(stored_values_sync_jobs::schema_name.eq(&schema_name.to_lowercase()))
.filter(stored_values_sync_jobs::table_name.eq(&table_name.to_lowercase()))
.filter(stored_values_sync_jobs::column_name.eq(&column_name.to_lowercase()))
.filter(stored_values_sync_jobs::status.eq("pending")) // Only pick up pending jobs
.select(stored_values_sync_jobs::id)
.order(stored_values_sync_jobs::created_at.desc()) // Get the most recent pending one