|
21 | 21 | parse_single_time_arg,
|
22 | 22 | parse_single_geo_arg,
|
23 | 23 | )
|
24 |
| -from .._query import QueryBuilder, execute_query, run_query, parse_row |
| 24 | +from .._query import QueryBuilder, execute_query, run_query, parse_row, filter_fields |
25 | 25 | from .._printer import create_printer, CSVPrinter
|
26 | 26 | from .._validate import (
|
27 | 27 | extract_date,
|
@@ -200,7 +200,7 @@ def gen(rows):
|
200 | 200 | raise DatabaseErrorException(str(e))
|
201 | 201 |
|
202 | 202 | # now use a generator for sending the rows and execute all the other queries
|
203 |
| - return p(gen(r)) |
| 203 | + return p(filter_fields(gen(r))) |
204 | 204 |
|
205 | 205 |
|
206 | 206 | @bp.route("/correlation", methods=("GET", "POST"))
|
@@ -260,7 +260,7 @@ def gen():
|
260 | 260 | yield cor.asdict()
|
261 | 261 |
|
262 | 262 | # now use a generator for sending the rows and execute all the other queries
|
263 |
| - return p(gen()) |
| 263 | + return p(filter_fields(gen())) |
264 | 264 |
|
265 | 265 |
|
266 | 266 | @bp.route("/csv", methods=("GET", "POST"))
|
@@ -405,7 +405,7 @@ def gen(rows):
|
405 | 405 | raise DatabaseErrorException(str(e))
|
406 | 406 |
|
407 | 407 | # now use a generator for sending the rows and execute all the other queries
|
408 |
| - return p(gen(r)) |
| 408 | + return p(filter_fields(gen(r))) |
409 | 409 |
|
410 | 410 |
|
411 | 411 | @bp.route("/meta", methods=("GET", "POST"))
|
|
0 commit comments