X-Git-Url: https://git.toastfreeware.priv.at/philipp/winterrodeln/wrpylib.git/blobdiff_plain/e70d420da8fc3e678156b5659bc4ccf3c5598e54..3a70956408c5dc9e999bb3600b509d60b866118d:/wrpylib/wrmwcache.py diff --git a/wrpylib/wrmwcache.py b/wrpylib/wrmwcache.py index 9aedf98..95e0e96 100644 --- a/wrpylib/wrmwcache.py +++ b/wrpylib/wrmwcache.py @@ -6,7 +6,7 @@ from sqlalchemy import schema from sqlalchemy.sql import select from sqlalchemy.sql.expression import func as sqlfunc from osgeo import ogr -from wrpylib import mwdb, wrmwdb, mwmarkup, wrmwmarkup, wrvalidators +from wrpylib import mwdb, wrmwdb, wrmwmarkup, wrvalidators class UpdateCacheError(RuntimeError): @@ -50,7 +50,7 @@ def update_wrsledruncache(connection): sledrun.page_id = sledrun_page.page_id sledrun.page_title = sledrun_page.page_title sledrun.name_url = wrvalidators.sledrun_page_title_to_pretty_url(sledrun_page.page_title) - sledrun.under_construction = connection.execute(select([categorylinks], (categorylinks.c.cl_from==sledrun_page.page_id) & (categorylinks.c.cl_to == 'In_Arbeit')).alias('x').count()).fetchone()[0] > 0 + sledrun.under_construction = connection.execute(select([sqlfunc.count()], (categorylinks.c.cl_from==sledrun_page.page_id) & (categorylinks.c.cl_to == 'In_Arbeit')).alias('x')).fetchone()[0] > 0 connection.execute(wrsledruncache.insert(sledrun.__dict__)) except ValueError as e: transaction.rollback() @@ -93,7 +93,7 @@ def update_wrinncache(connection): inn = wrmwmarkup.inn_from_gasthausbox(gasthausbox, Inn()) inn.page_id = inn_page.page_id inn.page_title = inn_page.page_title - inn.under_construction = connection.execute(select([categorylinks], (categorylinks.c.cl_from==inn_page.page_id) & (categorylinks.c.cl_to == 'In_Arbeit')).alias('x').count()).fetchone()[0] > 0 # It would be better to do this in the query above + inn.under_construction = connection.execute(select([sqlfunc.count()], (categorylinks.c.cl_from==inn_page.page_id) & (categorylinks.c.cl_to == 'In_Arbeit')).alias('x')).fetchone()[0] > 0 # It would be better to do this in the query above connection.execute(wrinncache.insert(inn.__dict__)) except ValueError as e: transaction.rollback()