diff options
Diffstat (limited to 'app/models/analytics/cycle_analytics/aggregation.rb')
-rw-r--r-- | app/models/analytics/cycle_analytics/aggregation.rb | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/app/models/analytics/cycle_analytics/aggregation.rb b/app/models/analytics/cycle_analytics/aggregation.rb index fa165ae9600..0f8e184933e 100644 --- a/app/models/analytics/cycle_analytics/aggregation.rb +++ b/app/models/analytics/cycle_analytics/aggregation.rb @@ -17,11 +17,13 @@ class Analytics::CycleAnalytics::Aggregation < ApplicationRecord end def consistency_check_cursor_for(model) + return {} if self["last_consistency_check_#{model.issuable_model.table_name}_issuable_id"].nil? + { :start_event_timestamp => self["last_consistency_check_#{model.issuable_model.table_name}_start_event_timestamp"], :end_event_timestamp => self["last_consistency_check_#{model.issuable_model.table_name}_end_event_timestamp"], model.issuable_id_column => self["last_consistency_check_#{model.issuable_model.table_name}_issuable_id"] - }.compact + } end def refresh_last_run(mode) |