Skip to content

Commit

Permalink
cmachak/bug-fix-tests (#23)
Browse files Browse the repository at this point in the history
* fix extra DBResource in test

* fix DatabricksResource construction
  • Loading branch information
xmachak authored Feb 14, 2024
1 parent 96df31f commit ca3ef43
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ name = "block-cascade"
packages = [
{include = "block_cascade"}
]
version = "2.4.5"
version = "2.4.6"
description = "Library for model training in multi-cloud environment."
readme = "README.md"
authors = ["Block"]
Expand Down
2 changes: 2 additions & 0 deletions tests/test_config.py
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ def gcp_resource(gcp_environment, gcp_machine_config):
@pytest.fixture()
def databricks_resource():
return DatabricksResource(
storage_location="s3://test-bucket/cascade",
worker_count=DatabricksAutoscaleConfig(min_workers=5, max_workers=10),
cloud_pickle_by_value=["a", "b"],
)
Expand Down Expand Up @@ -107,6 +108,7 @@ def test_databricks_resource(
configuration = f"""
{test_job_name}:
type: DatabricksResource
storage_location: {databricks_resource.storage_location}
worker_count:
min_workers: {databricks_resource.worker_count.min_workers}
max_workers: {databricks_resource.worker_count.max_workers}
Expand Down
2 changes: 0 additions & 2 deletions tests/test_databricks_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,6 @@
from block_cascade.executors.databricks.job import DatabricksJob
from block_cascade.utils import wrapped_partial

databricks_resource = DatabricksResource()

# Mocks paths
MOCK_CLUSTER_POLICY = (
"block_cascade.executors.DatabricksExecutor.get_cluster_policy_id_from_policy_name"
Expand Down

0 comments on commit ca3ef43

Please sign in to comment.