equal
deleted
inserted
replaced
20 from collections import defaultdict |
20 from collections import defaultdict |
21 from itertools import chain |
21 from itertools import chain |
22 import logging |
22 import logging |
23 from uuid import uuid4 |
23 from uuid import uuid4 |
24 |
24 |
25 from six import text_type |
|
26 from six.moves import range |
|
27 |
|
28 from cubicweb.dataimport import stores, pgstore |
25 from cubicweb.dataimport import stores, pgstore |
29 from cubicweb.server.schema2sql import eschema_sql_def |
26 from cubicweb.server.schema2sql import eschema_sql_def |
30 |
27 |
31 |
28 |
32 class MassiveObjectStore(stores.RQLObjectStore): |
29 class MassiveObjectStore(stores.RQLObjectStore): |
68 - `metagen`, optional :class:`MetadataGenerator` instance |
65 - `metagen`, optional :class:`MetadataGenerator` instance |
69 - `eids_seq_range`: size of eid range reserved by the store for each batch |
66 - `eids_seq_range`: size of eid range reserved by the store for each batch |
70 """ |
67 """ |
71 super(MassiveObjectStore, self).__init__(cnx) |
68 super(MassiveObjectStore, self).__init__(cnx) |
72 |
69 |
73 self.uuid = text_type(uuid4()).replace('-', '') |
70 self.uuid = str(uuid4()).replace('-', '') |
74 self.slave_mode = slave_mode |
71 self.slave_mode = slave_mode |
75 if metagen is None: |
72 if metagen is None: |
76 metagen = stores.MetadataGenerator(cnx) |
73 metagen = stores.MetadataGenerator(cnx) |
77 self.metagen = metagen |
74 self.metagen = metagen |
78 |
75 |