From 004d8a59ffe389eb6f389dd86103316905af5262 Mon Sep 17 00:00:00 2001 From: Jasper Ginn Date: Sat, 19 Oct 2024 19:57:12 +0200 Subject: [PATCH] chore: clean --- tests/dagster_pyiceberg_pandas/conftest.py | 30 ---------------------- 1 file changed, 30 deletions(-) diff --git a/tests/dagster_pyiceberg_pandas/conftest.py b/tests/dagster_pyiceberg_pandas/conftest.py index 2ffa623..80ba662 100644 --- a/tests/dagster_pyiceberg_pandas/conftest.py +++ b/tests/dagster_pyiceberg_pandas/conftest.py @@ -1,37 +1,7 @@ -import datetime as dt -import random - -import pyarrow as pa import pytest -# from pyiceberg import table as iceberg_table -# from pyiceberg import transforms as T -# from pyiceberg.catalog.sql import SqlCatalog - @pytest.fixture(scope="session", autouse=True) def warehouse_path(tmp_path_factory) -> str: dir_ = tmp_path_factory.mktemp("warehouse") return str(dir_.resolve()) - - -@pytest.fixture(scope="session") -def data() -> pa.Table: - random.seed(876) - N = 1440 - d = { - "timestamp": pa.array( - [ - dt.datetime(2023, 1, 1, 0, 0, 0) + dt.timedelta(minutes=i) - for i in range(N) - ] - ), - "category": pa.array([random.choice(["A", "B", "C"]) for _ in range(N)]), - "value": pa.array(random.uniform(0, 1) for _ in range(N)), - } - return pa.Table.from_pydict(d) - - -@pytest.fixture(scope="session") -def schema(data: pa.Table) -> pa.Schema: - return data.schema