refactor load_pricing_data for explicit asset dependency

Author: digitalghost-dev

card_data/pipelines/defs/load/load_pricing_data.py

@@ -1,4 +1,5 @@
 import dagster as dg
+import polars as pl
 from dagster import RetryPolicy, Backoff
 from sqlalchemy.exc import OperationalError
 from ..extract.extract_pricing_data import build_dataframe
@@ -7,17 +8,15 @@
 
 
 @dg.asset(
-    deps=[build_dataframe],
     kinds={"Supabase", "Postgres"},
     retry_policy=RetryPolicy(max_retries=3, delay=2, backoff=Backoff.EXPONENTIAL),
 )
-def load_pricing_data() -> None:
+def load_pricing_data(build_pricing_dataframe: pl.DataFrame) -> None:
     database_url: str = fetch_secret()
     table_name: str = "staging.pricing_data"
 
-    df = build_dataframe()
     try:
-        df.write_database(
+        build_pricing_dataframe.write_database(
             table_name=table_name, connection=database_url, if_table_exists="replace"
         )
         print(colored(" ✓", "green"), f"Data loaded into {table_name}")