Pull the database name for the Postgres connection only from the connection definition #117
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Background: the Airflow Postgres connection uses the
schema
parameter to specify the database (see: https://airflow.apache.org/docs/apache-airflow-providers-postgres/stable/connections/postgres.html). This lead to a double use of theself.schema
attribute in the operator in case of using it with postgres, both for the database and the schema which in effect meant if those values were not the same it did not work.This PR changes the postgres connection to use the
schema
parameter defined in the connection itself as the database name and use theschema
parameter of the operator (or aschema.table
notation for thedata_asset
parameter) as the schema within the GX context.