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

stored values casing for jobs

This commit is contained in:
dal 2025-05-09 16:23:58 -06:00
parent c30b6b893b
commit d16f3296b2
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
api/libs/handlers/src/datasets/deploy.rs
View File

@ -310,10 +310,10 @@ pub async fn deploy_datasets_handler_core(
if let Err(e) = stored_values_jobs::setup_sync_job( if let Err(e) = stored_values_jobs::setup_sync_job(
job_data_source_id, job_data_source_id,
current_job_database_name.clone(), current_job_database_name.clone().to_lowercase(),
current_job_schema_name.clone(), current_job_schema_name.clone().to_lowercase(),
job_table_name.clone(), job_table_name.clone().to_lowercase(),
job_column_name.clone(), job_column_name.clone().to_lowercase(),
) )
.await .await
{ {
@ -326,10 +326,10 @@ pub async fn deploy_datasets_handler_core(
match stored_values_jobs::sync_distinct_values_chunk( match stored_values_jobs::sync_distinct_values_chunk(
job_data_source_id, job_data_source_id,
current_job_database_name, current_job_database_name.clone().to_lowercase(),
current_job_schema_name, current_job_schema_name.clone().to_lowercase(),
job_table_name, job_table_name.clone().to_lowercase(),
job_column_name, job_column_name.clone().to_lowercase(),
).await { ).await {
Ok(count) => info!( Ok(count) => info!(
"Successfully synced {} distinct values for searchable dimension '{}' (data_source_id: {}).", "Successfully synced {} distinct values for searchable dimension '{}' (data_source_id: {}).",

2
api/server/src/main.rs
View File

@ -69,7 +69,7 @@ async fn main() -> Result<(), anyhow::Error> {
info!("Starting stored values sync job scheduler..."); info!("Starting stored values sync job scheduler...");
// Schedule to run every hour // Schedule to run every hour
let job = Job::new_async("0 */5 * * * *", move |uuid, mut l| { let job = Job::new_async("*/5 * * * * *", move |uuid, mut l| {
Box::pin(async move { Box::pin(async move {
info!(job_uuid = %uuid, "Running hourly stored values sync job check."); info!(job_uuid = %uuid, "Running hourly stored values sync job check.");
if let Err(e) = trigger_stale_sync_jobs().await { if let Err(e) = trigger_stale_sync_jobs().await {