commit bf0a5b4b822a9e4889ddf3902646e04a603ae778 · edavis.dev/monarch

+1 -1

cmd/backfiller/cursors.go

···

       10
       10
        
       )

     

       11
       11
        
       

     

       12
       12
        
       type cursorRecord struct {

     

       13
       13
       -
       	ID  uint `gorm:"primaryKey"`

     

       13
       13
       +
       	ID  uint   `gorm:"primaryKey"`

     

       14
       14
        
       	Key string `gorm:"unique"`

     

       15
       15
        
       	Val string

     

       16
       16
        
       }

+4 -1

cmd/backfiller/main.go

···

       116
       116
        
       		sl.Error("failed to start scheduler", "err", err)

     

       117
       117
        
       	}

     

       118
       118
        
       	<-ctx.Done()

     

       119
       119
       -
       	bf.Stop(context.TODO())

     

       119
       119
       +
       

     

       120
       120
       +
       	endctx, cancel := context.WithTimeout(ctx, time.Minute)

     

       121
       121
       +
       	defer cancel()

     

       122
       122
       +
       	bf.Stop(endctx)

     

       120
       123
        
       }