aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorXinhui2017-08-29 11:51:08 +0200
committerXinhui2017-08-29 11:51:08 +0200
commita64bf1115eedf12af4effc5556042a3cfd9493bb (patch)
treed639a5af0781bf2e057f048afcfe618b98e38f71
parentf8ec55f2f708b3e463a3167eab336af010af00a4 (diff)
downloadchouette-core-a64bf1115eedf12af4effc5556042a3cfd9493bb.tar.bz2
Add condition on reset of LineReferentialSyncs/StopAreaReferentialSyncs by sidekiq initializer
Refs #4314
-rw-r--r--config/initializers/sidekiq.rb12
1 files changed, 7 insertions, 5 deletions
diff --git a/config/initializers/sidekiq.rb b/config/initializers/sidekiq.rb
index ac31d43e7..e44d8df52 100644
--- a/config/initializers/sidekiq.rb
+++ b/config/initializers/sidekiq.rb
@@ -1,8 +1,10 @@
Sidekiq.configure_server do |config|
- [
- LineReferentialSync.pending,
- StopAreaReferentialSync.pending
- ].each do |pendings|
- pendings.map { |sync| sync.failed({error: 'Failed by Sidekiq reboot', processing_time: 0}) }
+ if ENV["CHOUETTE_SIDEKIQ_CANCEL_SYNCS_ON_BOOT"]
+ [
+ LineReferentialSync.pending,
+ StopAreaReferentialSync.pending
+ ].each do |pendings|
+ pendings.map { |sync| sync.failed({error: 'Failed by Sidekiq reboot', processing_time: 0}) }
+ end
end
end