summaryrefslogtreecommitdiff
path: root/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/container_expiration_policies/cleanup_container_repository_worker.rb')
-rw-r--r--app/workers/container_expiration_policies/cleanup_container_repository_worker.rb27
1 files changed, 26 insertions, 1 deletions
diff --git a/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb b/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
index 8c3c2e9e103..7c86b194574 100644
--- a/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
+++ b/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
@@ -12,6 +12,14 @@ module ContainerExpirationPolicies
worker_resource_boundary :unknown
idempotent!
+ LOG_ON_DONE_FIELDS = %i[
+ cleanup_status
+ cleanup_tags_service_original_size
+ cleanup_tags_service_before_truncate_size
+ cleanup_tags_service_after_truncate_size
+ cleanup_tags_service_before_delete_size
+ ].freeze
+
def perform_work
return unless throttling_enabled?
return unless container_repository
@@ -26,7 +34,7 @@ module ContainerExpirationPolicies
result = ContainerExpirationPolicies::CleanupService.new(container_repository)
.execute
- log_extra_metadata_on_done(:cleanup_status, result.payload[:cleanup_status])
+ log_on_done(result)
end
def remaining_work_count
@@ -92,5 +100,22 @@ module ContainerExpirationPolicies
def log_info(extra_structure)
logger.info(structured_payload(extra_structure))
end
+
+ def log_on_done(result)
+ LOG_ON_DONE_FIELDS.each do |field|
+ value = result.payload[field]
+
+ next if value.nil?
+
+ log_extra_metadata_on_done(field, value)
+ end
+
+ before_truncate_size = result.payload[:cleanup_tags_service_before_truncate_size]
+ after_truncate_size = result.payload[:cleanup_tags_service_after_truncate_size]
+ truncated = before_truncate_size &&
+ after_truncate_size &&
+ before_truncate_size != after_truncate_size
+ log_extra_metadata_on_done(:cleanup_tags_service_truncated, !!truncated)
+ end
end
end