🚧 Change cosmos to use connectio

Author: chris-s-friedman

dags/kids_first/dbt_bash.py

@@ -50,9 +50,9 @@
     def check_for_warehouse_host_var():
         warehouse_host = Variable.get("INCLUDEWAREHOUSE_HOST", default=None)
         if warehouse_host:
-            print("WAREHOUSE_HOST exists!")
+            print("INCLUDEWAREHOUSE_HOST exists!")
         else:
-            print("WAREHOUSE_HOST variable is not set.")
+            print("INCLUDEWAREHOUSE_HOST variable is not set.")
 
     t2 = PythonOperator(
         task_id="check_for_warehouse_host_var",

dags/kids_first/example_study.py

@@ -9,11 +9,14 @@
     ExecutionConfig,
     RenderConfig,
 )
+from cosmos.profiles import PostgresUserPasswordProfileMapping
 
 profile_config = ProfileConfig(
     profile_name=Variable.get("DBT_PROFILE_NAME"),
-    profiles_yml_filepath=Variable.get("DBT_PROFILES_YML_PATH"),
     target_name="prd",
+    profile_mapping=PostgresUserPasswordProfileMapping(
+        conn_id="postgres_dev_svc"
+    ),
 )
 
 example_study_dag = DbtDag(