File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff 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' ))
You can’t perform that action at this time.
0 commit comments