terminate worker actors after task is complete - fix memory leaks

obi-a · Jul 10, 2017 · ade9696 · ade9696
1 parent 981e992
commit ade9696
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/lib/ragios/events/worker.rb b/lib/ragios/events/worker.rb
@@ -7,6 +7,7 @@ def perform(options)
         puts options.inspect
         @event =  JSON.parse(options, symbolize_names: true)
         log_event
+        terminate
       end
 
     private

diff --git a/lib/ragios/monitors/workers/worker.rb b/lib/ragios/monitors/workers/worker.rb
@@ -17,6 +17,7 @@ def perform(monitor_id)
             type: "event",
             event_type: "monitor.test"
           )
+          terminate
         rescue Exception => e
           log_error(e, generic_monitor)
           raise e

diff --git a/lib/ragios/notifications/notify_worker.rb b/lib/ragios/notifications/notify_worker.rb
@@ -21,13 +21,13 @@ def perform(event, monitor, test_result, notifier)
         publisher.async.log_event!(
           event_details.merge(event: occurred)
         )
-
+        terminate
       rescue Exception => exception
-        raise
         occurred = {"notifier error" => exception.message}
         publisher.async.log_event!(
           event_details.merge(event: occurred)
         )
+        raise exception
       end
 
     private