|
1 | 1 | from datetime import date, datetime
|
2 | 2 | from functools import partial
|
3 |
| -from itertools import groupby |
4 | 3 | from pathlib import Path
|
5 | 4 | from typing import Iterable, List, Optional, Union
|
6 | 5 |
|
| 6 | +from itertools import groupby |
7 | 7 | from splitgill.manager import SplitgillClient, SplitgillDatabase
|
8 | 8 | from splitgill.model import Record
|
9 | 9 | from splitgill.utils import partition, now
|
|
26 | 26 | from dataimporter.lib.config import Config
|
27 | 27 | from dataimporter.lib.dbs import Store
|
28 | 28 | from dataimporter.lib.model import SourceRecord
|
29 |
| -from dataimporter.lib.options import DEFAULT_OPTIONS |
| 29 | +from dataimporter.lib.options import PARSING_OPTIONS |
30 | 30 | from dataimporter.lib.view import View
|
31 | 31 |
|
32 | 32 |
|
@@ -305,7 +305,7 @@ def add_to_mongo(self, view_name: str, everything: bool = False) -> Optional[int
|
305 | 305 |
|
306 | 306 | database.ingest(records, commit=False, modified_field="modified")
|
307 | 307 | # send the options anyway, even if there's no change to them
|
308 |
| - database.update_options(DEFAULT_OPTIONS, commit=False) |
| 308 | + database.update_options(PARSING_OPTIONS, commit=False) |
309 | 309 | committed = database.commit()
|
310 | 310 | # flush the queue as we've handled everything in it now
|
311 | 311 | view.flush()
|
|
0 commit comments