diff --git a/api/libs/handlers/src/datasets/deploy.rs b/api/libs/handlers/src/datasets/deploy.rs index df109ca64..21bb5e6bb 100644 --- a/api/libs/handlers/src/datasets/deploy.rs +++ b/api/libs/handlers/src/datasets/deploy.rs @@ -310,10 +310,10 @@ pub async fn deploy_datasets_handler_core( if let Err(e) = stored_values_jobs::setup_sync_job( job_data_source_id, - current_job_database_name.clone(), - current_job_schema_name.clone(), - job_table_name.clone(), - job_column_name.clone(), + current_job_database_name.clone().to_lowercase(), + current_job_schema_name.clone().to_lowercase(), + job_table_name.clone().to_lowercase(), + job_column_name.clone().to_lowercase(), ) .await { @@ -326,10 +326,10 @@ pub async fn deploy_datasets_handler_core( match stored_values_jobs::sync_distinct_values_chunk( job_data_source_id, - current_job_database_name, - current_job_schema_name, - job_table_name, - job_column_name, + current_job_database_name.clone().to_lowercase(), + current_job_schema_name.clone().to_lowercase(), + job_table_name.clone().to_lowercase(), + job_column_name.clone().to_lowercase(), ).await { Ok(count) => info!( "Successfully synced {} distinct values for searchable dimension '{}' (data_source_id: {}).", diff --git a/api/server/src/main.rs b/api/server/src/main.rs index 31f7f8e68..550fae76c 100644 --- a/api/server/src/main.rs +++ b/api/server/src/main.rs @@ -69,7 +69,7 @@ async fn main() -> Result<(), anyhow::Error> { info!("Starting stored values sync job scheduler..."); // 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 { info!(job_uuid = %uuid, "Running hourly stored values sync job check."); if let Err(e) = trigger_stale_sync_jobs().await {