Update webhookworker.py

Map-A-Droid · Sep 16, 2024 · cf1610e · cf1610e
1 parent a2860b1
commit cf1610e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/mapadroid/webhook/webhookworker.py b/mapadroid/webhook/webhookworker.py
@@ -691,8 +691,9 @@ async def __create_payload(self):
             try:
                 # stations
                 if 'station' in self.__webhook_types:
-                    stations = self.__prepare_station_data(session, self.__last_check)
+                    stations = await self.__prepare_station_data(session, self.__last_check)
                     full_payload += stations
+
                 # raids
                 if 'raid' in self.__webhook_types:
                     raids = self.__prepare_raid_data(
@@ -770,7 +771,7 @@ async def __run_worker(self):
 
         logger.info("Stopping webhook worker thread")
 
-    def __prepare_station_data(self, session: AsyncSession, _timestamp: int):
+    async def __prepare_station_data(self, session: AsyncSession, _timestamp: int):
         logger.debug2("WebhookWorker/DbWebhookReader::__prepare_stations_data called with timestamp {}", _timestamp)
 
         ret = []