Skip to content

Commit

Permalink
✨ Changed flow name to TransformAndCatalogToLuma
Browse files Browse the repository at this point in the history
  • Loading branch information
Rafalz13 committed Sep 21, 2023
1 parent a5702b8 commit 16d94ff
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions viadot/flows/transform_and_catalog.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ def _cleanup_repo(dbt_repo_dir_name: str) -> None:
shutil.rmtree(dbt_repo_dir_name, ignore_errors=True) # Delete folder on run


class TransformAndCatalog(Flow):
class TransformAndCatalogToLuma(Flow):
"""Build specified dbt model(s) and upload the generated metadata to Luma catalog."""

def __init__(
Expand Down Expand Up @@ -48,8 +48,8 @@ def __init__(
Args:
name (str): The name of the Flow.
dbt_project_path (str): The path to the dbt project (the directory containing
the `dbt_project.yml` file).
dbt_project_path (str, optional): The path to the dbt project (the directory containing
the `dbt_project.yml` file). Defaults to 'tmp_dbt_repo_dir'.
dbt_repo_url (str, optional): The URL for cloning the dbt repo with relevant dbt project. Defaults to None.
dbt_repo_url_secret (str, optional): Alternatively to above, the secret containing `dbt_repo_url`.
Defaults to None.
Expand Down Expand Up @@ -78,12 +78,12 @@ def __init__(
# Build a single model
```python
import os
from viadot.flows import TransformAndCatalog
from viadot.flows import TransformAndCatalogToLuma
my_dbt_project_path = os.path.expanduser("~/dbt/my_dbt_project")
flow = TransformAndCatalog(
name="Transform and Catalog",
flow = TransformAndCatalogToLuma(
name="Transform and Catalog to Luma",
dbt_project_path=my_dbt_project_path,
dbt_repo_url=my_dbt_repo_url,
token=my_token,
Expand Down

0 comments on commit 16d94ff

Please sign in to comment.