|
10 | 10 | import aiohttp |
11 | 11 | import pandas as pd |
12 | 12 | import requests |
13 | | -from databento.common.enums import ( |
14 | | - Compression, |
15 | | - Dataset, |
16 | | - Delivery, |
17 | | - Encoding, |
18 | | - Packaging, |
19 | | - Schema, |
20 | | - SplitDuration, |
21 | | - SType, |
22 | | -) |
23 | | -from databento.common.parsing import ( |
24 | | - datetime_to_string, |
25 | | - optional_datetime_to_string, |
26 | | - optional_symbols_list_to_string, |
27 | | - optional_values_list_to_string, |
28 | | -) |
29 | | -from databento.common.validation import ( |
30 | | - validate_enum, |
31 | | - validate_path, |
32 | | - validate_semantic_string, |
33 | | -) |
34 | | -from databento.historical.api import API_VERSION |
35 | | -from databento.historical.http import ( |
36 | | - BentoHttpAPI, |
37 | | - check_http_error, |
38 | | - check_http_error_async, |
39 | | -) |
40 | 13 | from requests.auth import HTTPBasicAuth |
41 | 14 |
|
| 15 | +from databento.common.enums import Compression |
| 16 | +from databento.common.enums import Dataset |
| 17 | +from databento.common.enums import Delivery |
| 18 | +from databento.common.enums import Encoding |
| 19 | +from databento.common.enums import Packaging |
| 20 | +from databento.common.enums import Schema |
| 21 | +from databento.common.enums import SplitDuration |
| 22 | +from databento.common.enums import SType |
| 23 | +from databento.common.parsing import datetime_to_string |
| 24 | +from databento.common.parsing import optional_datetime_to_string |
| 25 | +from databento.common.parsing import optional_symbols_list_to_string |
| 26 | +from databento.common.parsing import optional_values_list_to_string |
| 27 | +from databento.common.validation import validate_enum |
| 28 | +from databento.common.validation import validate_path |
| 29 | +from databento.common.validation import validate_semantic_string |
| 30 | +from databento.historical.api import API_VERSION |
| 31 | +from databento.historical.http import BentoHttpAPI |
| 32 | +from databento.historical.http import check_http_error |
| 33 | +from databento.historical.http import check_http_error_async |
| 34 | + |
42 | 35 |
|
43 | 36 | logger = logging.getLogger(__name__) |
44 | 37 |
|
@@ -129,7 +122,7 @@ def submit_job( |
129 | 122 | params: List[Tuple[str, Optional[str]]] = [ |
130 | 123 | ("dataset", validate_semantic_string(dataset, "dataset")), |
131 | 124 | ("start", datetime_to_string(start)), |
132 | | - ("end", datetime_to_string(end)), |
| 125 | + ("end", optional_datetime_to_string(end)), |
133 | 126 | ("symbols", str(symbols_list)), |
134 | 127 | ("schema", str(validate_enum(schema, Schema, "schema"))), |
135 | 128 | ("stype_in", str(stype_in_valid)), |
|
0 commit comments