diff --git a/cosmos/profiles/postgres/user_pass.py b/cosmos/profiles/postgres/user_pass.py index 22e47bc6a..b0c785d20 100644 --- a/cosmos/profiles/postgres/user_pass.py +++ b/cosmos/profiles/postgres/user_pass.py @@ -46,6 +46,9 @@ def profile(self) -> dict[str, Any | None]: "password": self.get_env_var_format("password"), } + if "schema" in self.profile_args: + profile["schema"] = self.get_env_var_format("schema") + return self.filter_null(profile) @property