Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
goodwanghan committed Mar 18, 2024
1 parent cb20623 commit dde578e
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 2 deletions.
3 changes: 3 additions & 0 deletions fugue_snowflake/execution_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,9 @@ def __init__(
SnowflakeClient.get_or_create(self.conf) if client is None else client
)

def _dummy_window_order_by(self) -> str:
return "ORDER BY 1"

@property
def is_distributed(self) -> bool:
return True
Expand Down
2 changes: 1 addition & 1 deletion fugue_snowflake/tester.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
@ft.fugue_test_backend
class SnowflakeTestBackend(ft.FugueTestBackend):
name = "snowflake"
default_fugue_conf: Dict[str, Any] = {}
default_fugue_conf: Dict[str, Any] = {"fugue.sf.packages": "pytest"}

@classmethod
@contextmanager
Expand Down
4 changes: 3 additions & 1 deletion tests/fugue_snowflake/test_execution_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,12 @@
import fugue.test as ft
from fugue_test.execution_suite import ExecutionEngineTests
from triad import to_uuid

import pyarrow as pa
from fugue_snowflake import SnowflakeDataFrame, SnowflakeExecutionEngine


@ft.fugue_test_suite("snowflake", mark_test=True)
class SnowflakeExecutionEngineTestsBase(ExecutionEngineTests.Tests):
equal_type_groups = [(pa.types.is_integer,)]

pass

0 comments on commit dde578e

Please sign in to comment.