@@ -136,6 +136,11 @@ def handle():
136
136
137
137
fields_string = ["geo_value" , "signal" ]
138
138
fields_int = ["time_value" , "direction" , "issue" , "lag" ]
139
+
140
+ missing_fields = ["missing_value" , "missing_stderr" , "missing_sample_size" ]
141
+ if sql_table_has_columns ("covidcast" , missing_fields ):
142
+ fields_int .extend (missing_fields )
143
+
139
144
fields_float = ["value" , "stderr" , "sample_size" ]
140
145
if is_compatibility_mode ():
141
146
q .set_order ("signal" , "time_value" , "geo_value" , "issue" )
@@ -145,14 +150,6 @@ def handle():
145
150
q .set_order ("source" , "signal" , "time_type" , "time_value" , "geo_type" , "geo_value" , "issue" )
146
151
q .set_fields (fields_string , fields_int , fields_float )
147
152
148
- missing_fields = ["missing_value" , "missing_stderr" , "missing_sample_size" ]
149
- fields_int .extend (missing_fields )
150
- if sql_table_has_columns ("covidcast" , missing_fields ):
151
- # real fields
152
- q .fields .extend ([f"{ q .alias } .{ field } " for field in missing_fields ])
153
- else :
154
- # fake fields
155
- q .fields .extend ([f"0 as { field } " for field in missing_fields ])
156
153
157
154
# basic query info
158
155
# data type of each field
0 commit comments