Revert "Ensure all Sidekiq queues are always alive"

This reverts commit bba787c06e.
This commit is contained in:
dump_stack() 2023-03-31 23:06:02 +00:00
parent bba787c06e
commit f2ea3d1c98
Signed by: dump_stack
GPG Key ID: BE44DA8C062D87DC

View File

@ -36,7 +36,6 @@ let
sidekiq-manager = pkgs.writers.writePython3 "sidekiq-manager" {} '' sidekiq-manager = pkgs.writers.writePython3 "sidekiq-manager" {} ''
from itertools import permutations from itertools import permutations
from subprocess import Popen from subprocess import Popen
from time import sleep
def sidekiq(queues, connections=16): def sidekiq(queues, connections=16):
@ -53,17 +52,6 @@ let
queues = ['default', 'push', 'ingress'] queues = ['default', 'push', 'ingress']
procs += [sidekiq(qs) for qs in permutations(queues)] procs += [sidekiq(qs) for qs in permutations(queues)]
for p in procs:
sleep(1)
if p.poll():
# one of the queues is dead
break
# terminate the rest queues
for p in procs:
# https://github.com/sidekiq/sidekiq/wiki/Signals#term
p.terminate()
for p in procs: for p in procs:
p.wait() p.wait()
''; '';