diff --git a/avalon/config/docker_schedule.rb b/avalon/config/docker_schedule.rb index e2a3731..377fe82 100644 --- a/avalon/config/docker_schedule.rb +++ b/avalon/config/docker_schedule.rb @@ -6,3 +6,11 @@ locking_sh "script/s3-dropbox-sync.sh", :lock_name => "s3_dropbox_sync" locking_rake "avalon:batch:ingest", :lock_name => "batch_ingest", :environment => ENV['RAILS_ENV'] || 'production' end + +every 15.minutes do + locking_rake "avalon:batch:ingest_status_check", :lock_name => "batch_ingest", :environment => ENV['RAILS_ENV'] || 'production' +end + +every 1.day do + locking_rake "avalon:batch:ingest_stalled_check", :lock_name => "batch_ingest", :environment => ENV['RAILS_ENV'] || 'production' +end diff --git a/avalon/s3-dropbox-sync.sh b/avalon/s3-dropbox-sync.sh index 1422d80..13dfee3 100755 --- a/avalon/s3-dropbox-sync.sh +++ b/avalon/s3-dropbox-sync.sh @@ -18,7 +18,7 @@ function get_s3_object_tag { get_s3_object_tags $1 | jq '.TagSet[] | select(.Key function get_s3_object_tag_value { get_s3_object_tag $1 $2 | jq -r .Value; } -function is_processed { if [ $(get_s3_object_tag_value $1 $CLIENT_NAME) = "processed" ]; then return 0; else return 1; fi; } +function is_processed { if [ "$(get_s3_object_tag_value $1 $CLIENT_NAME)" = "processed" ]; then return 0; else return 1; fi; } mp3_files_synced=0 csv_files_synced=0