in aepsych/server.py [0:0]
def handle_tell(self, request):
logger.debug("got tell message!")
if not self.is_performing_replay:
self.db.record_message(
master_table=self._db_master_record, type="tell", request=request
)
# Batch update mode
if type(request["message"]) == list:
for msg in request["message"]:
self.tell(**msg)
else:
self.tell(**request["message"])
if self.strat is not None and self.strat.finished is True:
logger.info("Recording strat because the experiment is complete.")
buffer = io.BytesIO()
torch.save(self.strat, buffer, pickle_module=dill)
buffer.seek(0)
self.db.record_strat(master_table=self._db_master_record, strat=buffer)
return "acq"