mirror
/
ogn-python
kopia lustrzana https://github.com/glidernet/ogn-python
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

flake8 fixes

pull/41/head
Konstantin Gründger 2016-02-11 08:08:11 +01:00
rodzic f3da85576c
commit 9b4a0124e8
1 zmienionych plików z 20 dodań i 20 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

40
ogn/collect/receiver.py
Wyświetl plik

@ -26,34 +26,34 @@ def update_receivers():
.subquery() .subquery()
receivers_to_update = app.session.query(ReceiverBeacon.name, receivers_to_update = app.session.query(ReceiverBeacon.name,
ReceiverBeacon.latitude, ReceiverBeacon.latitude,
ReceiverBeacon.longitude, ReceiverBeacon.longitude,
ReceiverBeacon.altitude, ReceiverBeacon.altitude,
last_receiver_beacon_sq.columns.lastseen, last_receiver_beacon_sq.columns.lastseen,
ReceiverBeacon.version, ReceiverBeacon.version,
ReceiverBeacon.platform) \ ReceiverBeacon.platform) \
.filter(and_(ReceiverBeacon.name == last_receiver_beacon_sq.columns.name, .filter(and_(ReceiverBeacon.name == last_receiver_beacon_sq.columns.name,
ReceiverBeacon.timestamp == last_receiver_beacon_sq.columns.lastseen)) \ ReceiverBeacon.timestamp == last_receiver_beacon_sq.columns.lastseen)) \
.subquery() .subquery()
# set country code to None if lat or lon changed # set country code to None if lat or lon changed
count = app.session.query(Receiver) \ count = app.session.query(Receiver) \
.filter(and_(Receiver.name == receivers_to_update.columns.name, .filter(and_(Receiver.name == receivers_to_update.columns.name,
or_(Receiver.latitude != receivers_to_update.columns.latitude, or_(Receiver.latitude != receivers_to_update.columns.latitude,
Receiver.longitude != receivers_to_update.columns.longitude))) \ Receiver.longitude != receivers_to_update.columns.longitude))) \
.update({"latitude": receivers_to_update.columns.latitude, .update({"latitude": receivers_to_update.columns.latitude,
"longitude": receivers_to_update.columns.longitude, "longitude": receivers_to_update.columns.longitude,
"country_code": null()}) "country_code": null()})
logger.info("Count of receivers who changed lat or lon: {}".format(count)) logger.info("Count of receivers who changed lat or lon: {}".format(count))
# update lastseen of known receivers # update lastseen of known receivers
count = app.session.query(Receiver) \ count = app.session.query(Receiver) \
.filter(Receiver.name == receivers_to_update.columns.name) \ .filter(Receiver.name == receivers_to_update.columns.name) \
.update({"altitude": receivers_to_update.columns.altitude, .update({"altitude": receivers_to_update.columns.altitude,
"lastseen": receivers_to_update.columns.lastseen, "lastseen": receivers_to_update.columns.lastseen,
"version": receivers_to_update.columns.version, "version": receivers_to_update.columns.version,
"platform": receivers_to_update.columns.platform}) "platform": receivers_to_update.columns.platform})
logger.info("Count of receivers who where updated: {}".format(count)) logger.info("Count of receivers who where updated: {}".format(count))