diff --git a/pyinfra/visitor/strategies/response/aggregation.py b/pyinfra/visitor/strategies/response/aggregation.py index b9489a5..d3845f9 100644 --- a/pyinfra/visitor/strategies/response/aggregation.py +++ b/pyinfra/visitor/strategies/response/aggregation.py @@ -50,11 +50,11 @@ class AggregationStorageStrategy(ResponseStrategy): self.storage.put_object(**object_descriptor, data=compress(data)) return {**storage_upload_info, "responseFile": object_descriptor["object_name"]} + def upload_queue_items(self, storage_upload_info): + data = json.dumps(self.merge_queue_items()).encode() + return self.put_object(data, storage_upload_info) + def merge_queue_items(self): merged_buffer_content = self.merger(self.buffer) self.buffer.clear() return merged_buffer_content - - def upload_queue_items(self, storage_upload_info): - data = json.dumps(self.merge_queue_items()).encode() - return self.put_object(data, storage_upload_info)