fixup

dagster-io · Sep 26, 2023 · 2adae73 · 2adae73
1 parent d8b2114
commit 2adae73
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 16 deletions.
diff --git a/purina_usage/assets/dbt_snowflake/__init__.py b/purina_usage/assets/dbt_snowflake/__init__.py
@@ -6,13 +6,6 @@
 from dagster import OpExecutionContext
 from dagster_cloud.metrics import store_dbt_adapter_metrics
 
-# snowflake_connection_details = SnowflakeConnectionDetails(
-#     user=os.getenv("SNOWFLAKE_USER", ""),
-#     password=os.getenv("SNOWFLAKE_PASSWORD", ""),
-#     account="na94824.us-east-1",
-#     warehouse="DEVELOPMENT",
-# )
-
 dbt_project_dir = Path(__file__).joinpath("..", "..", "..", "..", "dbt_project").resolve()
 dbt_cli_resource = DbtCliResource(
     project_dir=os.fspath(dbt_project_dir),

diff --git a/purina_usage/assets/raw_data/__init__.py b/purina_usage/assets/raw_data/__init__.py
@@ -11,15 +11,6 @@
 @asset(compute_kind="random")
 def users(context: OpExecutionContext) -> Generator[Output[pd.DataFrame], Any, Any]:
     """A table containing all users data."""
-    put_context_metrics(
-        context,
-        metrics=[
-            DagsterMetric(
-                metric_name="snowflake_credits",
-                metric_value=122.22,
-            )
-        ],
-    )
     data = pd.DataFrame(
         {
             "user_id": range(1000),