@@ -41,7 +41,7 @@ class LogSubscriber < ::ActiveSupport::LogSubscriber
4141 sig { params ( event : T . untyped ) . void }
4242 def enqueue ( event )
4343 job_data = extract_job_data ( event )
44-
44+
4545 log_entry = LogStruct ::Log ::GoodJob . new (
4646 event : Event ::Enqueue ,
4747 level : Level ::Info ,
@@ -64,7 +64,7 @@ def enqueue(event)
6464 sig { params ( event : T . untyped ) . void }
6565 def start ( event )
6666 job_data = extract_job_data ( event )
67-
67+
6868 log_entry = LogStruct ::Log ::GoodJob . new (
6969 event : Event ::Start ,
7070 level : Level ::Info ,
@@ -82,11 +82,11 @@ def start(event)
8282 logger . info ( log_entry )
8383 end
8484
85- # Job completed successfully event
85+ # Job completed successfully event
8686 sig { params ( event : T . untyped ) . void }
8787 def finish ( event )
8888 job_data = extract_job_data ( event )
89-
89+
9090 log_entry = LogStruct ::Log ::GoodJob . new (
9191 event : Event ::Finish ,
9292 level : Level ::Info ,
@@ -110,7 +110,7 @@ def finish(event)
110110 sig { params ( event : T . untyped ) . void }
111111 def error ( event )
112112 job_data = extract_job_data ( event )
113-
113+
114114 log_entry = LogStruct ::Log ::GoodJob . new (
115115 event : Event ::Error ,
116116 level : Level ::Error ,
@@ -134,7 +134,7 @@ def error(event)
134134 sig { params ( event : T . untyped ) . void }
135135 def schedule ( event )
136136 job_data = extract_job_data ( event )
137-
137+
138138 log_entry = LogStruct ::Log ::GoodJob . new (
139139 event : Event ::Schedule ,
140140 level : Level ::Info ,
@@ -166,7 +166,7 @@ def extract_job_data(event)
166166 # Basic job information
167167 if job
168168 data [ :job_id ] = job . job_id if job . respond_to? ( :job_id )
169- data [ :job_class ] = job . job_class if job . respond_to? ( :job_class )
169+ data [ :job_class ] = job . job_class if job . respond_to? ( :job_class )
170170 data [ :queue_name ] = job . queue_name if job . respond_to? ( :queue_name )
171171 data [ :arguments ] = job . arguments if job . respond_to? ( :arguments )
172172 data [ :priority ] = job . priority if job . respond_to? ( :priority )
@@ -210,7 +210,7 @@ def calculate_wait_time(execution)
210210 return nil unless execution . created_at && execution . performed_at
211211
212212 ( execution . performed_at - execution . created_at ) . to_f
213- rescue => e
213+ rescue
214214 # Return nil if calculation fails
215215 nil
216216 end
@@ -225,4 +225,4 @@ def logger
225225 end
226226 end
227227 end
228- end
228+ end
0 commit comments