jobs_defs.py

from sqlalchemy import text
from sqlalchemy import orm
from sqlalchemy.dialects.postgresql import JSONB
from sqlalchemy.sql.expression import func

from app import db
import app
from jobs import update_registry
from jobs import Update

from models.product import Product
from models.person import Person
from models import person

q = db.session.query(Person.id)
q = q.filter(Person.orcid_id != None)
q = q.order_by(func.random())
update_registry.register(Update(
    job=Person.refresh,
    query=q,
    queue_id=0
))

q = db.session.query(Person.id)
q = q.filter(Person.claimed_at != None)
update_registry.register(Update(
    job=Person.email_new_stuff,
    query=q,
))


q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.calculate,
    query=q,
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.call_oadoi,
    query=q
))


q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.call_oadoi_on_everything,
    query=q,
    queue_id=0
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_from_orcid,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_fulltext_urls,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_mendeley,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_mendeley_sums,
    query=q
))

q = db.session.query(Product.id)
q = q.filter(Product.altmetric_api_raw != None)
q = q.filter(Product.altmetric_api_raw != {})
q = q.filter(Product.event_dates == None)
update_registry.register(Update(
    job=Product.set_event_dates,
    query=q
))

q = db.session.query(Product.id)
q = q.filter(Product.altmetric_api_raw != None)
q = q.filter(Product.altmetric_score == None)
update_registry.register(Update(
    job=Product.set_altmetric_score,
    query=q
))

q = db.session.query(Product.id)
q = q.filter(Product.altmetric_api_raw != None)
update_registry.register(Update(
    job=Product.set_altmetric_id,
    query=q
))

q = db.session.query(Product.id)
q = q.filter(Product.post_counts != None)
q = q.filter(Product.post_counts != {})
update_registry.register(Update(
    job=Product.set_post_details,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_post_details,
    query=q
))

# q = db.session.query(Person.id)
# update_registry.register(Update(
#     job=Person.email_new_badge,
#     query=q
# ))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_coauthors,
    query=q
))

q = db.session.query(Person.id)
q = q.filter(Person.twitter != None)
update_registry.register(Update(
    job=Person.update_twitter_profile_data,
    query=q
))



q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.run_log_openness,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.set_num_oa_licenses,
    query=q
))


q = db.session.query(Person.id)
# q = q.filter(Person.orcid_id.in_([
#             "0000-0002-6133-2581",
#             "0000-0002-0159-2197",
#             "0000-0003-1613-5981",
#             "0000-0003-1419-2405",
#             "0000-0001-6187-6610",
#             "0000-0001-6728-7745"]))
update_registry.register(Update(
    job=Person.set_badge_percentiles,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.assign_badges,
    query=q,
    shortcut_fn=lambda: ["open_license", "percent_fulltext", "all_fulltext"]
))

q = db.session.query(Person.id)
# q = q.filter(Person.updated < '2016-04-10 10:00:51.972209')
update_registry.register(Update(
    job=Person.refresh_from_db,
    query=q
))

q = db.session.query(Person.id)
update_registry.register(Update(
    job=Person.all_products_set_biblio_from_orcid,
    query=q
))