From 48e3c690cedf6ada1e46ff9a3b3c7fbd823a5ec7 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Fri, 19 Jan 2024 17:47:14 -0500 Subject: [PATCH] feat: register storage service with cron --- storage/storage.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/storage/storage.go b/storage/storage.go index fa68ab5..b5f4e14 100644 --- a/storage/storage.go +++ b/storage/storage.go @@ -216,10 +216,16 @@ func (s *StorageServiceImpl) Init() error { s.tus = tus s.tusStore = store + s.portal.CronService().RegisterService(s) + go s.tusWorker() return nil } +func (s *StorageServiceImpl) LoadInitialTasks(cron interfaces.CronService) error { + return nil +} + func (s *StorageServiceImpl) createBucketIfNotExists(bucket string) error { resp, err := s.httpApi.R(). SetPathParam("bucket", bucket).