discourse/app/jobs/regular/run_heartbeat.rb

# frozen_string_literal: true

# This job is deprecated and will be removed in the future. The only reason it exists is for clean up purposes.
module Jobs
  class RunHeartbeat < ::Jobs::Base
    def self.heartbeat_key
      "heartbeat_last_run"
    end

    def execute(args)
      Discourse.redis.del(self.class.heartbeat_key)
    end
  end
end
DEV: enable frozen string literal on all files This reduces chances of errors where consumers of strings mutate inputs and reduces memory usage of the app. Test suite passes now, but there may be some stuff left, so we will run a few sites on a branch prior to merging 2019-05-03 08:17:27 +10:00			`# frozen_string_literal: true`

FIX: Redo Sidekiq monitoring to restart stuck sidekiq processes (#30198) This commit reimplements how we monitor Sidekiq processes that are forked from the Unicorn master process. Prior to this change, we rely on `Jobs::Heartbeat` to enqueue a `Jobs::RunHeartbeat` job every 3 minutes. The `Jobs::RunHeartbeat` job then sets a Redis key with a timestamp. In the Unicorn master process, we then fetch the timestamp that has been set by the job from Redis every 30 minutes. If the timestamp has not been updated for more than 30 minutes, we restart the Sidekiq process. The fundamental flaw with this approach is that it fails to consider deployments with multiple hosts and multiple Sidekiq processes. A sidekiq process on a host may be in a bad state but the heartbeat check will not restart the process because the `Jobs::RunHeartbeat` job is still being executed by the working Sidekiq processes on other hosts. In order to properly ensure that stuck Sidekiq processs are restarted, we now rely on the [Sidekiq::ProcessSet](https://github.com/sidekiq/sidekiq/wiki/API#processes) API that is supported by Sidekiq. The API provides us with "near real-time (updated every 5 sec) info about the current set of Sidekiq processes running". The API provides useful information like the hostname, pid and also when Sidekiq last did its own heartbeat check. With that information, we can easily determine if a Sidekiq process needs to be restarted from the Unicorn master process. 2024-12-18 12:48:50 +08:00			`# This job is deprecated and will be removed in the future. The only reason it exists is for clean up purposes.`
FEATURE: unicorn sidekiq will restart sidekiq on complete failure. (checks every 30 minutes for complete failure) 2014-04-23 13:13:18 +10:00			`module Jobs`
DEV: Upgrading Discourse to Zeitwerk (#8098) Zeitwerk simplifies working with dependencies in dev and makes it easier reloading class chains. We no longer need to use Rails "require_dependency" anywhere and instead can just use standard Ruby patterns to require files. This is a far reaching change and we expect some followups here. 2019-10-02 14:01:53 +10:00			`class RunHeartbeat < ::Jobs::Base`
Revert "Revert "Revert "FIX: Heartbeat check per sidekiq process (#7873)""" This reverts commit c3497559be71598f1ae06677c0225bb4322e1688. 2019-08-30 11:26:16 +01:00			`def self.heartbeat_key`
DEV: Apply syntax_tree formatting to `app/*` 2023-01-09 12:20:10 +00:00			`"heartbeat_last_run"`
Revert "Revert "Revert "FIX: Heartbeat check per sidekiq process (#7873)""" This reverts commit c3497559be71598f1ae06677c0225bb4322e1688. 2019-08-30 11:26:16 +01:00			`end`

FEATURE: unicorn sidekiq will restart sidekiq on complete failure. (checks every 30 minutes for complete failure) 2014-04-23 13:13:18 +10:00			`def execute(args)`
FIX: Redo Sidekiq monitoring to restart stuck sidekiq processes (#30198) This commit reimplements how we monitor Sidekiq processes that are forked from the Unicorn master process. Prior to this change, we rely on `Jobs::Heartbeat` to enqueue a `Jobs::RunHeartbeat` job every 3 minutes. The `Jobs::RunHeartbeat` job then sets a Redis key with a timestamp. In the Unicorn master process, we then fetch the timestamp that has been set by the job from Redis every 30 minutes. If the timestamp has not been updated for more than 30 minutes, we restart the Sidekiq process. The fundamental flaw with this approach is that it fails to consider deployments with multiple hosts and multiple Sidekiq processes. A sidekiq process on a host may be in a bad state but the heartbeat check will not restart the process because the `Jobs::RunHeartbeat` job is still being executed by the working Sidekiq processes on other hosts. In order to properly ensure that stuck Sidekiq processs are restarted, we now rely on the [Sidekiq::ProcessSet](https://github.com/sidekiq/sidekiq/wiki/API#processes) API that is supported by Sidekiq. The API provides us with "near real-time (updated every 5 sec) info about the current set of Sidekiq processes running". The API provides useful information like the hostname, pid and also when Sidekiq last did its own heartbeat check. With that information, we can easily determine if a Sidekiq process needs to be restarted from the Unicorn master process. 2024-12-18 12:48:50 +08:00			`Discourse.redis.del(self.class.heartbeat_key)`
FEATURE: unicorn sidekiq will restart sidekiq on complete failure. (checks every 30 minutes for complete failure) 2014-04-23 13:13:18 +10:00			`end`
			`end`
			`end`