Manager: log duration of job deletion
When a job has been deleted, log how long it took to delete.
This commit is contained in:
parent
5ec479a983
commit
390cb9445c
@ -196,6 +196,7 @@ queueLoop:
|
|||||||
|
|
||||||
func (s *Service) deleteJob(ctx context.Context, jobUUID string) error {
|
func (s *Service) deleteJob(ctx context.Context, jobUUID string) error {
|
||||||
logger := log.With().Str("job", jobUUID).Logger()
|
logger := log.With().Str("job", jobUUID).Logger()
|
||||||
|
startTime := time.Now()
|
||||||
|
|
||||||
logger.Debug().Msg("job deleter: starting job deletion")
|
logger.Debug().Msg("job deleter: starting job deletion")
|
||||||
err := s.deleteShamanCheckout(ctx, logger, jobUUID)
|
err := s.deleteShamanCheckout(ctx, logger, jobUUID)
|
||||||
@ -225,7 +226,10 @@ func (s *Service) deleteJob(ctx context.Context, jobUUID string) error {
|
|||||||
}
|
}
|
||||||
s.changeBroadcaster.BroadcastJobUpdate(jobUpdate)
|
s.changeBroadcaster.BroadcastJobUpdate(jobUpdate)
|
||||||
|
|
||||||
logger.Info().Msg("job deleter: job removal complete")
|
duration := time.Since(startTime)
|
||||||
|
logger.Info().
|
||||||
|
Stringer("duration", duration).
|
||||||
|
Msg("job deleter: job removal complete")
|
||||||
|
|
||||||
// Request a consistency check on the database. In the past there have been
|
// Request a consistency check on the database. In the past there have been
|
||||||
// some issues after deleting a job.
|
// some issues after deleting a job.
|
||||||
|
Loading…
Reference in New Issue
Block a user