Fix Pyre errors in sqa_classes

Summary: Use `annotations` to properly annotate Ax SQA class `Column` attributes

Differential Revision: D60612786

ax/storage/sqa_store/decoder.py

@@ -297,8 +297,8 @@ def parameter_from_sqa(self, parameter_sqa: SQAParameter) -> Parameter:
             parameter = RangeParameter(
                 name=parameter_sqa.name,
                 parameter_type=parameter_sqa.parameter_type,
-                lower=parameter_sqa.lower,
-                upper=parameter_sqa.upper,
+                lower=float(not_none(parameter_sqa.lower)),
+                upper=float(not_none(parameter_sqa.upper)),
                 log_scale=parameter_sqa.log_scale or False,
                 digits=parameter_sqa.digits,
                 is_fidelity=parameter_sqa.is_fidelity or False,
@@ -392,7 +392,7 @@ def parameter_constraint_from_sqa(
                 )
             a = a_values[0]
             is_upper_bound = a == 1
-            bound = parameter_constraint_sqa.bound * a
+            bound = float(parameter_constraint_sqa.bound) * a
             constraint = SumConstraint(
                 parameters=constraint_parameters,
                 is_upper_bound=is_upper_bound,
@@ -401,7 +401,7 @@ def parameter_constraint_from_sqa(
         else:
             constraint = ParameterConstraint(
                 constraint_dict=dict(parameter_constraint_sqa.constraint_dict),
-                bound=parameter_constraint_sqa.bound,
+                bound=float(parameter_constraint_sqa.bound),
             )
 
         constraint.db_id = parameter_constraint_sqa.id
@@ -441,8 +441,8 @@ def environmental_variable_from_sqa(self, parameter_sqa: SQAParameter) -> Parame
             parameter = RangeParameter(
                 name=parameter_sqa.name,
                 parameter_type=parameter_sqa.parameter_type,
-                lower=parameter_sqa.lower,
-                upper=parameter_sqa.upper,
+                lower=float(not_none(parameter_sqa.lower)),
+                upper=float(not_none(parameter_sqa.upper)),
                 log_scale=parameter_sqa.log_scale or False,
                 digits=parameter_sqa.digits,
                 is_fidelity=parameter_sqa.is_fidelity or False,
@@ -675,8 +675,16 @@ def generator_run_from_sqa(
             weights=weights,
             optimization_config=opt_config,
             search_space=search_space,
-            fit_time=generator_run_sqa.fit_time,
-            gen_time=generator_run_sqa.gen_time,
+            fit_time=(
+                None
+                if generator_run_sqa.fit_time is None
+                else float(generator_run_sqa.fit_time)
+            ),
+            gen_time=(
+                None
+                if generator_run_sqa.gen_time is None
+                else float(generator_run_sqa.gen_time)
+            ),
             best_arm_predictions=best_arm_predictions,  # pyre-ignore[6]
             # pyre-fixme[6]: Expected `Optional[Tuple[typing.Dict[str, List[float]],
             #  typing.Dict[str, typing.Dict[str, List[float]]]]]` for 8th param but got
@@ -865,7 +873,7 @@ def trial_from_sqa(
                         reduced_state=reduced_state,
                         immutable_search_space_and_opt_config=immutable_ss_and_oc,
                     ),
-                    weight=generator_run_sqa.weight or 1.0,
+                    weight=float(generator_run_sqa.weight or 1.0),
                 )
                 for generator_run_sqa in trial_sqa.generator_runs
             ]
@@ -1134,9 +1142,9 @@ def _outcome_constraint_from_sqa(
             )
         return OutcomeConstraint(
             metric=metric,
-            bound=metric_sqa.bound,
-            op=metric_sqa.op,
-            relative=metric_sqa.relative,
+            bound=float(not_none(metric_sqa.bound)),
+            op=not_none(metric_sqa.op),
+            relative=not_none(metric_sqa.relative),
         )
 
     def _scalarized_outcome_constraint_from_sqa(
@@ -1180,7 +1188,7 @@ def _scalarized_outcome_constraint_from_sqa(
         scalarized_outcome_constraint = ScalarizedOutcomeConstraint(
             metrics=list(metrics),
             weights=list(weights),
-            bound=not_none(metric_sqa.bound),
+            bound=float(not_none(metric_sqa.bound)),
             op=not_none(metric_sqa.op),
             relative=not_none(metric_sqa.relative),
         )
@@ -1197,8 +1205,8 @@ def _objective_threshold_from_sqa(
             )
         ot = ObjectiveThreshold(
             metric=metric,
-            bound=metric_sqa.bound,
-            relative=metric_sqa.relative,
+            bound=float(not_none(metric_sqa.bound)),
+            relative=not_none(metric_sqa.relative),
             op=metric_sqa.op,
         )
         # ObjectiveThreshold constructor clones the passed-in metric, which means

ax/storage/sqa_store/load.py

@@ -238,7 +238,7 @@ def _get_trials_sqa(
         mini_batch_db_ids = trial_db_ids[batch_size * i : batch_size * (i + 1)]
         with session_scope() as session:
             query = session.query(trial_sqa_class).filter(
-                trial_sqa_class.id.in_(mini_batch_db_ids)  # pyre-ignore[16]
+                trial_sqa_class.id.in_(mini_batch_db_ids)
             )
 
             if trials_query_options is not None:

ax/storage/sqa_store/save.py

@@ -281,11 +281,9 @@ def trial_to_reduced_state_sqa_encoder(t: BaseTrial) -> SQATrial:
         # saved data if it's no longer on the experiment.
         with session_scope() as session:
             session.query(data_sqa_class).filter_by(experiment_id=experiment_id).filter(
-                data_sqa_class.trial_index.isnot(None)  # pyre-ignore[16]
-            ).filter(
-                data_sqa_class.trial_index.in_(trial_idcs)  # pyre-ignore[16]
-            ).filter(
-                data_sqa_class.id.not_in(datas_to_keep)  # pyre-ignore[16]
+                data_sqa_class.trial_index.isnot(None)
+            ).filter(data_sqa_class.trial_index.in_(trial_idcs)).filter(
+                data_sqa_class.id not in datas_to_keep
             ).delete()
 
     _bulk_merge_into_session(
@@ -421,7 +419,7 @@ def update_outcome_constraint_on_experiment(
 ) -> None:
     oc_sqa_class = encoder.config.class_to_sqa_class[Metric]
 
-    exp_id = experiment.db_id
+    exp_id: Optional[int] = experiment.db_id
     if exp_id is None:
         raise UserInputError("Experiment must be saved before being updated.")
     oc_id = outcome_constraint.db_id
@@ -431,9 +429,7 @@ def update_outcome_constraint_on_experiment(
                 id=oc_id
             ).delete()
 
-    # pyre-fixme[53]: Captured variable `exp_id` is not annotated.
-    # pyre-fixme[3]: Return type must be annotated.
-    def add_experiment_id(sqa: SQAMetric):
+    def add_experiment_id(sqa: SQAMetric) -> None:
         sqa.experiment_id = exp_id
 
     encode_func = (