|
1 | | -from io import BytesIO |
| 1 | +# from io import BytesIO |
2 | 2 |
|
3 | | -import pytest |
4 | | -from etl_utils.io import pkl_dump_lz4, pkl_dumps_lz4, pkl_load_lz4 |
5 | | -from etl_utils.io.test.io_utils import pkl_loads_lz4 |
6 | | -from event.json import json_load |
| 3 | +# from etl_utils.io import pkl_dump_lz4, pkl_dumps_lz4, pkl_load_lz4 |
| 4 | +# from etl_utils.io.test.io_utils import pkl_loads_lz4 |
| 5 | +# from event.json import json_load |
| 6 | +# import pytest |
7 | 7 |
|
8 | | -from etl.sds.tests.constants import EtlTestDataPath |
| 8 | +# from etl.sds.tests.constants import EtlTestDataPath |
9 | 9 |
|
10 | 10 |
|
11 | | -@pytest.mark.s3(EtlTestDataPath.FULL_JSON) |
12 | | -def test_pkl_lz4(test_data_paths): |
13 | | - (path,) = test_data_paths |
14 | | - with open(path, "rb") as f: |
15 | | - data = json_load(f) |
| 11 | +# @pytest.mark.s3(EtlTestDataPath.FULL_JSON) Uncomment this when archived |
| 12 | +# def test_pkl_lz4(test_data_paths): |
| 13 | +# (path,) = test_data_paths |
| 14 | +# with open(path, "rb") as f: |
| 15 | +# data = json_load(f) |
16 | 16 |
|
17 | | - buffer = BytesIO() |
18 | | - pkl_dump_lz4(fp=buffer, obj=data) |
19 | | - buffer.seek(0) |
20 | | - assert pkl_load_lz4(fp=buffer) == data |
| 17 | +# buffer = BytesIO() |
| 18 | +# pkl_dump_lz4(fp=buffer, obj=data) |
| 19 | +# buffer.seek(0) |
| 20 | +# assert pkl_load_lz4(fp=buffer) == data |
21 | 21 |
|
22 | 22 |
|
23 | | -@pytest.mark.s3(EtlTestDataPath.FULL_JSON) |
24 | | -def test_pkl_lz4_bytes(test_data_paths): |
25 | | - (path,) = test_data_paths |
26 | | - with open(path, "rb") as f: |
27 | | - data = json_load(f) |
| 23 | +# @pytest.mark.s3(EtlTestDataPath.FULL_JSON) Uncomment this when archived |
| 24 | +# def test_pkl_lz4_bytes(test_data_paths): |
| 25 | +# (path,) = test_data_paths |
| 26 | +# with open(path, "rb") as f: |
| 27 | +# data = json_load(f) |
28 | 28 |
|
29 | | - data_as_bytes = pkl_dumps_lz4(obj=data) |
30 | | - assert pkl_loads_lz4(data=data_as_bytes) == data |
| 29 | +# data_as_bytes = pkl_dumps_lz4(obj=data) |
| 30 | +# assert pkl_loads_lz4(data=data_as_bytes) == data |
0 commit comments