~james-w/udd/management-commands

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
from udd import (
    icommon,
    iconfig,
    lpapi,
    )


def main():
    conf = iconfig.ImporterStack()
    lock = icommon.lock_path(conf.get('pi.script_locks_dir'), 'add_import_jobs')
    if lock is None:
        print "Another instance of add_import_jobs is already running."
        return
    try:
        lp = lpapi.get_lp()
        status_db = icommon.StatusDatabase(conf.get('pi.sqlite_file'))
        icommon.create_import_jobs(lp, status_db)
    finally:
        lock.close()
    return 0