|
32 | 32 | require_all,
|
33 | 33 | require_any,
|
34 | 34 | )
|
35 |
| -from .._db import sql_table_has_columns |
36 | 35 | from .._pandas import as_pandas, print_pandas
|
37 | 36 | from .covidcast_utils import compute_trend, compute_trends, compute_correlations, compute_trend_value, CovidcastMetaEntry, AllSignalsMap
|
38 | 37 | from ..utils import shift_time_value, date_to_time_value, time_value_to_iso, time_value_to_date
|
@@ -136,13 +135,9 @@ def handle():
|
136 | 135 | q = QueryBuilder("covidcast", "t")
|
137 | 136 |
|
138 | 137 | fields_string = ["geo_value", "signal"]
|
139 |
| - fields_int = ["time_value", "direction", "issue", "lag"] |
140 |
| - |
141 |
| - missing_fields = ["missing_value", "missing_stderr", "missing_sample_size"] |
142 |
| - if sql_table_has_columns("covidcast", missing_fields): |
143 |
| - fields_int.extend(missing_fields) |
144 |
| - |
| 138 | + fields_int = ["time_value", "direction", "issue", "lag", "missing_value", "missing_stderr", "missing_sample_size"] |
145 | 139 | fields_float = ["value", "stderr", "sample_size"]
|
| 140 | + |
146 | 141 | if is_compatibility_mode():
|
147 | 142 | q.set_order("signal", "time_value", "geo_value", "issue")
|
148 | 143 | else:
|
|
0 commit comments