Skip to content

Commit e0b1cf7

Browse files
committed
allow nan values to replicate
1 parent 9145ecb commit e0b1cf7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

singer/messages.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -218,12 +218,12 @@ def parse_message(msg):
218218
return None
219219

220220

221-
def format_message(message, ensure_ascii=True):
222-
return json.dumps(message.asdict(), use_decimal=True, ensure_ascii=ensure_ascii)
221+
def format_message(message, ensure_ascii=True, allow_nan=False):
222+
return json.dumps(message.asdict(), use_decimal=True, ensure_ascii=ensure_ascii, allow_nan=allow_nan)
223223

224224

225-
def write_message(message, ensure_ascii=True):
226-
sys.stdout.write(format_message(message, ensure_ascii=ensure_ascii) + '\n')
225+
def write_message(message, ensure_ascii=True, allow_nan=False):
226+
sys.stdout.write(format_message(message, ensure_ascii=ensure_ascii, allow_nan=allow_nan) + '\n')
227227
sys.stdout.flush()
228228

229229

0 commit comments

Comments
 (0)