diff --git a/aqua_importer.py b/aqua_importer.py index 11356d7..fad1618 100644 --- a/aqua_importer.py +++ b/aqua_importer.py @@ -246,9 +246,9 @@ class Importer: return tmp - async def get_chuni_card_id_by_aqua_row(self, row: Row, user_id_column: str = "user_id"): + def get_chuni_card_id_by_aqua_row(self, row: Row, user_id_column: str = "user_id"): aqua_user_id = row._asdict()[user_id_column] - user_result = await self.aqua.execute( + user_result = self.aqua.execute( f"SELECT * FROM chusan_user_data WHERE id = {aqua_user_id}" )