We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 38b89d5 commit b6b28baCopy full SHA for b6b28ba
warehouse/oso_dagster/utils/dynamic.py
@@ -64,7 +64,7 @@ def get_dynamic_replication(
64
cur = postgres_conn.cursor()
65
cur.execute(
66
DYNAMIC_REPLICATION_DATA_QUERY,
67
- (org_name, resource_name),
+ [org_name, resource_name],
68
)
69
result = cur.fetchone()
70
if not result:
@@ -81,7 +81,7 @@ def get_dynamic_replications_partition_for_type(
81
82
83
PARTITION_KEY_FOR_TYPE_QUERY,
84
- (replication_type,),
+ [replication_type.value],
85
86
results = cur.fetchall()
87
0 commit comments