stay away from direct database access

ManageIQ · Jul 24, 2019 · 31f7a6e · 31f7a6e · djberg96 · Sep 19, 2019
1 parent 514ca8b
commit 31f7a6e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 13 deletions.
diff --git a/app/models/manageiq/providers/azure/cloud_manager/event_catcher/runner.rb b/app/models/manageiq/providers/azure/cloud_manager/event_catcher/runner.rb
@@ -26,18 +26,7 @@ def process_event(event)
     else
       _log.info("#{log_prefix} Caught event #{parse_event_type(event)} for #{event["resourceId"]}")
       event_hash = ManageIQ::Providers::Azure::CloudManager::EventParser.event_to_hash(event, @cfg[:ems_id])
-
-      event_filter = {
-        :event_type => event_hash[:event_type],
-        :vm_ems_ref => event_hash[:vm_ems_ref],
-        :timestamp  => DateTime.parse(event_hash[:timestamp]),
-      }
-
-      if EmsEvent.where(event_filter).exists?
-        _log.info("#{log_prefix} Skipping duplicated Azure event #{event_hash[:event_type]} for #{event["resourceId"]}")
-      else
-        EmsEvent.add_queue('add', @cfg[:ems_id], event_hash)
-      end
+      EmsEvent.add_queue('add', @cfg[:ems_id], event_hash)
     end
   end
 

diff --git a/app/models/manageiq/providers/azure/cloud_manager/event_catcher/stream.rb b/app/models/manageiq/providers/azure/cloud_manager/event_catcher/stream.rb
@@ -40,7 +40,7 @@ def get_events
   end
 
   def startup_interval
-    format_timestamp(5.minutes.ago)
+    format_timestamp(1.minute.ago)
   end
 
   def one_ms_from_last_timestamp(events)