diff --git a/lib/que/job_methods.rb b/lib/que/job_methods.rb index 7bb99042..38ab7959 100644 --- a/lib/que/job_methods.rb +++ b/lib/que/job_methods.rb @@ -62,8 +62,13 @@ def _run(args: nil, kwargs: nil, reraise_errors: false) args: args, kwargs: kwargs, ) - run(*args, **kwargs) + Que.log( + level: :info, + event: :run_completed, + job_id: que_target.que_attrs[:id], + message: 'Run completed', + ) default_resolve_action if que_target && !que_target.que_resolved rescue => error Que.log(