|
@@ -236,8 +236,12 @@ class Filter(object): |
|
|
metadata = self._client_dest.stream_get_metadata(self.dest.path) |
|
|
metadata = self._client_dest.stream_get_metadata(self.dest.path) |
|
|
if not self.force_metadata: |
|
|
if not self.force_metadata: |
|
|
for key in data: |
|
|
for key in data: |
|
|
wanted = str(data[key]) |
|
|
|
|
|
|
|
|
wanted = data[key] |
|
|
val = metadata.get(key, wanted) |
|
|
val = metadata.get(key, wanted) |
|
|
|
|
|
# Force UTF-8 encoding for comparison and display |
|
|
|
|
|
wanted = wanted.encode('utf-8') |
|
|
|
|
|
val = val.encode('utf-8') |
|
|
|
|
|
key = key.encode('utf-8') |
|
|
if val != wanted and self.dest.rows > 0: |
|
|
if val != wanted and self.dest.rows > 0: |
|
|
m = "Metadata in destination stream:\n" |
|
|
m = "Metadata in destination stream:\n" |
|
|
m += " %s = %s\n" % (key, val) |
|
|
m += " %s = %s\n" % (key, val) |
|
|