Skip to content

Commit 1d0416c

Browse files
author
Nick McCoy
committed
Adding commas to fix error
1 parent 23b316c commit 1d0416c

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

singer/messages.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -166,15 +166,15 @@ def parse_message(msg):
166166
if msg_type == 'RECORD':
167167
return RecordMessage(stream=_required_key(obj, 'stream'),
168168
record=_required_key(obj, 'record'),
169-
time_extracted= obj.get('time_extracted')
170-
version=obj.get('version'))
169+
version=obj.get('version'),
170+
time_extracted= obj.get('time_extracted'))
171171

172172

173173
elif msg_type == 'SCHEMA':
174174
return SchemaMessage(stream=_required_key(obj, 'stream'),
175175
schema=_required_key(obj, 'schema'),
176-
key_properties=_required_key(obj, 'key_properties')
177-
bookmark_properties= obj.get('bookmark_properties') )
176+
key_properties=_required_key(obj, 'key_properties'),
177+
bookmark_properties= obj.get('bookmark_properties'))
178178

179179
elif msg_type == 'STATE':
180180
return StateMessage(value=_required_key(obj, 'value'))

0 commit comments

Comments
 (0)