Skip to content

Commit

Permalink
another one
Browse files Browse the repository at this point in the history
  • Loading branch information
nancyhung committed Jan 12, 2024
1 parent b3c820e commit bbcac42
Showing 1 changed file with 9 additions and 2 deletions.
11 changes: 9 additions & 2 deletions scripts/data_prep/convert_delta_to_json.py
Original file line number Diff line number Diff line change
Expand Up @@ -382,8 +382,15 @@ def validate_and_get_cluster_info(cluster_id: str,
databricks_token: str,
http_path: Optional[str],
use_serverless: bool = False) -> tuple:
"""Validate and get cluster info for running the Delta to JSONL
conversion."""
"""Validate and get cluster info for running the Delta to JSONL conversion.
Args:
cluster_id (str): cluster id to validate and fetch additional info for
databricks_host (str): databricks host name
databricks_token (str): databricks auth token
http_path (Optional[str]): http path to use for sql connect
use_serverless (bool): whether to use serverless or not
"""
method = 'dbsql'
dbsql = None
sparkSession = None
Expand Down

0 comments on commit bbcac42

Please sign in to comment.