From 7e4c9cea44569b444cb417cea2a5369c6ab1e064 Mon Sep 17 00:00:00 2001 From: Damian Lippok Date: Mon, 13 Jun 2022 18:38:36 +0200 Subject: [PATCH] Allow creating queries with reparitioning --- clin/clients/nakadi_sql.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clin/clients/nakadi_sql.py b/clin/clients/nakadi_sql.py index 46f7b80..8714a0a 100644 --- a/clin/clients/nakadi_sql.py +++ b/clin/clients/nakadi_sql.py @@ -120,7 +120,7 @@ def sql_query_to_payload(sql_query: SqlQuery) -> dict: } if sql_query.output_event_type.repartitioning: - payload["repartition_parameters"] = { + payload["output_event_type"]["repartition_parameters"] = { "number_of_partitions": sql_query.output_event_type.repartitioning.partition_count, "partition_strategy": str( sql_query.output_event_type.repartitioning.strategy