|
10 | 10 | from .packet import BinLogPacketWrapper
|
11 | 11 | from .constants.BINLOG import TABLE_MAP_EVENT, ROTATE_EVENT
|
12 | 12 | from .gtid import GtidSet
|
13 |
| -import event |
14 |
| -import row_event |
| 13 | +from .event import QueryEvent, RotateEvent, FormatDescriptionEvent, XidEvent, GtidEvent, NotImplementedEvent |
| 14 | +from .row_event import UpdateRowsEvent, WriteRowsEvent, DeleteRowsEvent, TableMapEvent |
15 | 15 |
|
16 | 16 | try:
|
17 | 17 | from pymysql.constants.COMMAND import COM_BINLOG_DUMP_GTID
|
@@ -261,23 +261,22 @@ def _allowed_event_list(self, only_events, ignored_events, filter_non_implemente
|
261 | 261 | events = set(only_events)
|
262 | 262 | else:
|
263 | 263 | events = set((
|
264 |
| - event.QueryEvent, |
265 |
| - event.RotateEvent, |
266 |
| - event.FormatDescriptionEvent, |
267 |
| - event.XidEvent, |
268 |
| - event.GtidEvent, |
269 |
| - # row_event |
270 |
| - row_event.UpdateRowsEvent, |
271 |
| - row_event.WriteRowsEvent, |
272 |
| - row_event.DeleteRowsEvent, |
273 |
| - row_event.TableMapEvent, |
274 |
| - event.NotImplementedEvent)) |
| 264 | + QueryEvent, |
| 265 | + RotateEvent, |
| 266 | + FormatDescriptionEvent, |
| 267 | + XidEvent, |
| 268 | + GtidEvent, |
| 269 | + UpdateRowsEvent, |
| 270 | + WriteRowsEvent, |
| 271 | + DeleteRowsEvent, |
| 272 | + TableMapEvent, |
| 273 | + NotImplementedEvent)) |
275 | 274 | if ignored_events is not None:
|
276 | 275 | for e in ignored_events:
|
277 | 276 | events.remove(e)
|
278 | 277 | if filter_non_implemented_events:
|
279 | 278 | try:
|
280 |
| - events.remove(event.NotImplementedEvent) |
| 279 | + events.remove(NotImplementedEvent) |
281 | 280 | except KeyError:
|
282 | 281 | pass
|
283 | 282 | return frozenset(events)
|
|
0 commit comments