Skip to content

Commit 48f7910

Browse files
rollakariv
authored andcommitted
Fixed saving hash/bytes to a resource (#118)
* Fixed saving hash/bytes to a resource * Fixed linting * Removed todos
1 parent efcfc0d commit 48f7910

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

dataflows/processors/dumpers/file_dumper.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,18 +78,24 @@ def rows_processor(self, resource, writer, temp_file):
7878
yield row
7979
writer.finalize_file()
8080

81+
# Get resource descriptor
82+
resource_descriptor = resource.res.descriptor
83+
for descriptor in self.datapackage.descriptor['resources']:
84+
if descriptor['name'] == resource.res.descriptor['name']:
85+
resource_descriptor = descriptor
86+
8187
# File size:
8288
filesize = temp_file.tell()
8389
DumperBase.inc_attr(self.datapackage.descriptor, self.datapackage_bytes, filesize)
84-
DumperBase.inc_attr(resource.res.descriptor, self.resource_bytes, filesize)
90+
DumperBase.inc_attr(resource_descriptor, self.resource_bytes, filesize)
8591

8692
# File Hash:
8793
if self.resource_hash:
8894
hasher = FileDumper.hash_handler(temp_file)
8995
# Update path with hash
9096
if self.add_filehash_to_path:
91-
DumperBase.insert_hash_in_path(resource.res.descriptor, hasher.hexdigest())
92-
DumperBase.set_attr(resource.res.descriptor, self.resource_hash, hasher.hexdigest())
97+
DumperBase.insert_hash_in_path(resource_descriptor, hasher.hexdigest())
98+
DumperBase.set_attr(resource_descriptor, self.resource_hash, hasher.hexdigest())
9399

94100
# Finalise
95101
filename = temp_file.name

0 commit comments

Comments
 (0)