diff --git a/app/helpers/service_helper.py b/app/helpers/service_helper.py index 06b1fa4..b0e9afb 100644 --- a/app/helpers/service_helper.py +++ b/app/helpers/service_helper.py @@ -13,20 +13,22 @@ def items_csv_to_dict(items_csv_reader, irt_model): else: item = { 'attributes': [] } - for key, col in enumerate(headers): - if key == 0: - item[col] = row[key] - # b param - tmep fix! use irt model b param for proper reference - elif key == (1 - len(headers)): - item['b_param'] = row[key] - elif key > 1: - item['attributes'].append({ - 'id': col, - 'value': row[key], - 'type': 'metadata' - }) + # ensure that the b param is formatted correctly + if len(re.findall(".", row[len(headers) - 1])) >= 3: + for key, col in enumerate(headers): + if key == 0: + item[col] = row[key] + # b param - tmep fix! use irt model b param for proper reference + elif key == len(headers) - 1: + item['b_param'] = row[key] + elif key > 1: + item['attributes'].append({ + 'id': col, + 'value': row[key], + 'type': 'metadata' + }) - items.append(item) + items.append(item) return items diff --git a/app/main.py b/app/main.py index 323dd5a..069575b 100644 --- a/app/main.py +++ b/app/main.py @@ -19,9 +19,9 @@ class ServiceListener(SqsListener): logging.info('Process complete for %s', service.file_name) def main(): - logging.info('Starting Solver Service (v1.0.1)...') + logging.info('Starting Solver Service (v1.0.9)...') listener = ServiceListener( - 'measure-development-solver-ingest', + os.environ['SQS_QUEUE'], region_name=os.environ['AWS_REGION'], aws_access_key=os.environ['AWS_ACCESS_KEY_ID'], aws_secret_key=os.environ['AWS_SECRET_ACCESS_KEY'], diff --git a/app/services/loft_service.py b/app/services/loft_service.py index 62410e3..e0fd6ed 100644 --- a/app/services/loft_service.py +++ b/app/services/loft_service.py @@ -63,6 +63,10 @@ class LoftService(Base): # create problem problem = LpProblem("ata-form-generate", LpMinimize) + # dummy objective function, because it just makes things easierâ„¢ + problem += lpSum([items[item.id] + for item in self.solver_run.items]) + # constraints problem += lpSum([items[item.id] for item in self.solver_run.items]) == self.solver_run.total_form_items, 'Total form items' @@ -72,21 +76,15 @@ class LoftService(Base): # multi-objective functions and constraints for target in self.solver_run.objective_function.tif_targets: - tif = lpSum([item.iif(self.solver_run, target.theta)*items[item.id] - for item in self.solver_run.items]) problem += lpSum([item.iif(self.solver_run, target.theta)*items[item.id] for item in self.solver_run.items]) <= target.value, f'min tif theta ({target.theta}) target value {target.value}' - problem_objection_functions.append(tif) for target in self.solver_run.objective_function.tcc_targets: - tcc = lpSum([item.irf(self.solver_run, target.theta)*items[item.id] - for item in self.solver_run.items]) problem += lpSum([item.irf(self.solver_run, target.theta)*items[item.id] for item in self.solver_run.items]) <= target.value, f'min tcc theta ({target.theta}) target value {target.value}' - problem_objection_functions.append(tcc) # solve problem - problem.sequentialSolve(problem_objection_functions) + problem.solve() # add return items and create as a form form_items = service_helper.solution_items(problem.variables(), self.solver_run)