File tree Expand file tree Collapse file tree 2 files changed +2
-7
lines changed Expand file tree Collapse file tree 2 files changed +2
-7
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,6 @@ def release
46
46
47
47
private
48
48
def execute
49
- SolidQueue . logger . info ( "[SolidQueue] Performing job #{ job . id } - #{ job . active_job_id } " )
50
49
ActiveJob ::Base . execute ( job . arguments )
51
50
Result . new ( true , nil )
52
51
rescue Exception => e
@@ -58,16 +57,12 @@ def finished
58
57
job . finished!
59
58
destroy!
60
59
end
61
-
62
- SolidQueue . logger . info ( "[SolidQueue] Performed job #{ job . id } - #{ job . active_job_id } " )
63
60
end
64
61
65
62
def failed_with ( error )
66
63
transaction do
67
64
job . failed_with ( error )
68
65
destroy!
69
66
end
70
-
71
- SolidQueue . logger . info ( "[SolidQueue] Failed job #{ job . id } - #{ job . active_job_id } " )
72
67
end
73
68
end
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ def shutdown
79
79
end
80
80
81
81
def graceful_termination
82
- procline "terminating gracefully"
82
+ SolidQueue . logger . info ( "[SolidQueue] Terminating gracefully..." )
83
83
term_forks
84
84
85
85
wait_until ( SolidQueue . shutdown_timeout , -> { all_forks_terminated? } ) do
@@ -90,7 +90,7 @@ def graceful_termination
90
90
end
91
91
92
92
def immediate_termination
93
- procline "terminating immediately"
93
+ SolidQueue . logger . info ( "[SolidQueue] Terminating immediately..." )
94
94
quit_forks
95
95
end
96
96
You can’t perform that action at this time.
0 commit comments