Skip to content

Commit 233df55

Browse files
authored
update redshift connection id to be consistent (#960)
1 parent a472ec6 commit 233df55

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

docs/integrations/engines.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -251,7 +251,7 @@ By default, the connection ID is set to `sqlmesh_redshift_default`, but it can b
251251
sqlmesh_airflow = SQLMeshAirflow(
252252
"redshift",
253253
engine_operator_args={
254-
"conn_id": "<Connection ID>"
254+
"redshift_conn_id": "<Connection ID>"
255255
},
256256
)
257257
```

sqlmesh/schedulers/airflow/operators/redshift.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,15 +14,16 @@ class SQLMeshRedshiftOperator(BaseSQLOperator):
1414
1515
Args:
1616
target: The target that will be executed by this operator instance.
17-
conn_id: The Airflow connection id for the Redshift target.
17+
redshift_conn_id: The Airflow connection id for the Redshift target.
1818
"""
1919

2020
def __init__(
2121
self,
2222
target: BaseTarget,
23+
redshift_conn_id: str = SQLMeshRedshiftHook.default_conn_name,
2324
**kwargs: t.Any,
2425
) -> None:
25-
super().__init__(conn_id=SQLMeshRedshiftHook.default_conn_name, **kwargs)
26+
super().__init__(conn_id=redshift_conn_id, **kwargs)
2627
self._target = target
2728

2829
def get_db_hook(self) -> SQLMeshRedshiftHook:

0 commit comments

Comments
 (0)