fix: reset pid if worker stopped

lib/treasury/supervisor.rb

@@ -1,5 +1,3 @@
-# coding: utf-8
-
 module Treasury
   class Supervisor
     STATE_RUNNING = 'running'.freeze

lib/treasury/utils.rb

@@ -65,9 +65,15 @@ def check_state(state)
 
     def set_state(state)
       return set_session if check_state(state) && process_is_alive?(@process_object.pid)
+
       @process_object.state = state
-      set_session
-      @process_object.save!
+
+      if state == 'stopped'
+        reset_session
+      else
+        set_session
+      end
+
       logger.info "Установлен статус %s" % [quote(@process_object.state)]
     end
 
@@ -77,6 +83,13 @@ def set_session
       logger.info "Установлен PID %s" % [quote(@process_object.pid)]
     end
 
+    def reset_session
+      @process_object.pid = nil
+      @process_object.save!
+
+      logger.info 'PID сброшен'
+    end
+
     def save_error(error_message)
       error_message = error_message[1, 4000] unless error_message.nil?
       @process_object.last_error = error_message

lib/treasury/worker.rb

@@ -1,5 +1,3 @@
-# coding: utf-8
-
 module Treasury
   class Worker
     STATE_RUNNING = 'running'.freeze