diff options
author | James Lopez <james@jameslopez.es> | 2018-06-25 16:10:26 +0300 |
---|---|---|
committer | James Lopez <james@jameslopez.es> | 2018-07-06 16:46:18 +0300 |
commit | a2bf1641546a1d3eeb3e9f44734854f655c0adef (patch) | |
tree | 0652c20a92513330aa09c4a2ec9adbfaeb3a6494 /app/services/import_export_clean_up_service.rb | |
parent | b0fa01fce3822da94aee6264829841996beb6df3 (diff) |
Update Import/Export to use object storage (based on aa feature flag)
Diffstat (limited to 'app/services/import_export_clean_up_service.rb')
-rw-r--r-- | app/services/import_export_clean_up_service.rb | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/app/services/import_export_clean_up_service.rb b/app/services/import_export_clean_up_service.rb index 74088b970c9..3702c3742ef 100644 --- a/app/services/import_export_clean_up_service.rb +++ b/app/services/import_export_clean_up_service.rb @@ -10,7 +10,9 @@ class ImportExportCleanUpService def execute Gitlab::Metrics.measure(:import_export_clean_up) do - next unless File.directory?(path) + clean_up_export_object_files + + break unless File.directory?(path) clean_up_export_files end @@ -21,4 +23,11 @@ class ImportExportCleanUpService def clean_up_export_files Gitlab::Popen.popen(%W(find #{path} -not -path #{path} -mmin +#{mmin} -delete)) end + + def clean_up_export_object_files + ImportExportUpload.where('updated_at < ?', mmin.minutes.ago).each do |upload| + upload.remove_export_file! + upload.save! + end + end end |