Commit c72a8f7

committed

adding error detail

1 parent 221ee02 commit c72a8f7Copy full SHA for c72a8f7

File tree

-2

lines changed

-2

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -156,8 +156,8 @@ def processor(data):`
`156`	`156`	`body = json.dumps(item['doc'], default=json_serializer)`
`157`	`157`	`rv = meta + '\n' + body`
`158`	`158`	`else:`
`159`		`- logging.error('unknown action type')`
`160`		`- raise TypeError('unknown action type')`
	`159`	`+ logging.error('unknown action type in doc')`
	`160`	`+ raise TypeError('unknown action type in doc')`
`161`	`161`	`yield rv`
`162`	`162`
`163`	`163`
`@@ -228,6 +228,9 @@ def binlog_loader():`
`228`	`228`	`'action': 'index',`
`229`	`229`	`'doc': row['values']`
`230`	`230`	`}`
	`231`	`+ else:`
	`232`	`+ logging.error('unknown action type in binlog')`
	`233`	`+ raise TypeError('unknown action type in binlog')`
`231`	`234`	`yield rv`
`232`	`235`	`# print(rv)`
`233`	`236`	`stream.close()`

Comments

(0)