Print a message instead of calling disco.util.msg().

This function printed the message in disco 0.4.5 and was deprecated.  In the new
version of disco, this function is not available.
This commit is contained in:
Shayan Pooya 2014-03-06 11:22:42 -05:00
Родитель 38bce073f4
Коммит 0ca0ae4b91
3 изменённых файлов: 4 добавлений и 6 удалений

Просмотреть файл

@ -10,7 +10,7 @@ def keyset_map(parts_, params_):
return unicode(value).encode('utf-8')
def _disco_message(message):
disco.util.msg(message)
print message
def _inferno_debug(params, message, *args):
if getattr(params, 'disco_debug', False):

Просмотреть файл

@ -19,8 +19,7 @@ def json_reader(stream, size=None, url=None, params=None):
assert isinstance(parts, dict)
except:
# just skip bad lines
import disco.util
disco.util.msg('json line error: %r' % line)
print 'json line error: %r' % line
else:
yield parts
@ -50,5 +49,4 @@ def csv_reader(stream, size=None, url=None, params=None):
done = True
except Exception as ee:
# just skip bad lines
import disco.util
disco.util.msg('csv line error: %s' % ee)
print 'csv line error: %s' % ee

Просмотреть файл

@ -10,7 +10,7 @@ def keyset_reduce(iter_, params_):
return unicode(value).encode('utf-8')
def _disco_message(message):
disco.util.msg(message)
print message
def _inferno_debug(params, message, *args):
if getattr(params, 'disco_debug', False):