Permalink
Browse files

Fix #62 Added path as key[0] for MultiMapper

Note: for all mapper added into MultiMapper input key is a tuple
with key[0] equal to pathname. This works regardless of "addpath" option.
  • Loading branch information...
1 parent beab85c commit f884844ac96e34e9813790de10d65366e0e0ce51 Mikhail Shevelev committed Nov 19, 2012
Showing with 1 addition and 2 deletions.
  1. +1 −2 dumbo/lib/__init__.py
View
@@ -125,7 +125,7 @@ def close(self):
def __call__normalkey(self, data):
mappers = self.mappers
for key, value in data:
- path, key = key
+ path = key[0]
for pattern, mapper in mappers:
if pattern in path:
for output in mapper(key, value):
@@ -135,7 +135,6 @@ def __call__joinkey(self, data):
mappers = self.mappers
for key, value in data:
path = key.body[0]
- key.body = key.body[1]
for pattern, mapper in mappers:
if pattern in path:
for output in mapper(key, value):

0 comments on commit f884844

Please sign in to comment.