fix query execution with limit option

fizaaluthra · Jun 30, 2017 · 45410dd · 45410dd
1 parent 2cc8e1d
commit 45410dd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cassandra-fdw/cassandra_provider.py b/cassandra-fdw/cassandra_provider.py
@@ -376,7 +376,7 @@ def build_select_stmt(self, quals, columns, allow_filtering, verbose=False):
                                     binding_values.append(types_mapper.map_object_to_type(qual.value, self.columnsTypes[qual.field_name]))
 
         if (self.limit):
-            stmt_str.write(u" LIMIT ".format(limit))
+            stmt_str.write(u" LIMIT {0}".format(self.limit))
         if allow_filtering:
             stmt_str.write(u" ALLOW FILTERING ")
         statement = stmt_str.getvalue()