jddlZddlZddlZddlZddlZddlmZddlmZm Z m Z dZ dZ dZ dZdZd Zd ejfd Zd ejd ed eefdZdeeefd eefdZdejdzd eeefdzfdZdejdzd eeefdzfdZdejdzd eeefdzfdZdejdzd eeefdzfdZdejdzd eeefdzfdZdejdzd eeefdzfdZdAdZ deeefd dfdZ!ded eeefdzfdZ" dBdedede#d edzd eeeeff d!Z$d"eeefd dfd#Z%d$ed eeefdzfd%Z&d&eeefd dfd'Z'd$ed e#fd(Z(dCd$ede#d eeeeffd*Z)d$ed+ed eeefdzfd,Z*dCde#d eeeeffd-Z+deeefd dfd.Z,ded eeefdzfd/Z-dDdedede#d eeeeffd0Z.deeefd dfd1Z/ded eeefdzfd2Z0dDdedede#d eeeeffd3Z1deeefd dfd4Z2ded eeefdzfd5Z3d eeefdzfd6Z4dDde#d eeeeffd7Z5dEdedede#d eeeeffd9Z6dEdedede#d eeeeffd:Z7dEde#d eeeeffd;Z8dFd=e#d e#fd>Z9dGd?eedzd e#fd@Z:dS)HN)Any) MODEL_DEFAULTSQLITE_DB_PATHlogger)job_typeid source_name source_type source_pathtemp_dirframe_intervalstatusmessagetotal processedkeptnotfoundfailed downloadedstart_tsend_ts owner_keyowner_ip conf_thresh batch_sizeimgsz classes_raw model_keyzip_paths_json result_dirresult_manifest_pathidentity_result_pathidentity_summary_json summary_text rnamenotesclass_names_jsonr image_count labeled_countreviewed_count version_countroot_dir created_ts updated_ts r dataset_idfilename origin_namer source_job_idsource_asset_id file_pathwidthheight size_bytesr.)rr1 dataset_namerr base_modelbase_model_path preset_keyepochsrrconfirmed_onlyrun_dirlog_path manifest_path artifact_dirr.rrrr)rr1r:rrrrrprompt_classes class_mapping overwriterrupdatedskipped_existing no_detectionr.rrrr ractionrrstagerrr.rrerror result_json library_jsonreturncTtjt}|rtj|dt jtd}t j|_| d| d| d|S)NT)exist_ok)timeoutzPRAGMA journal_mode=WALzPRAGMA busy_timeout=30000zPRAGMA synchronous=NORMAL) ospathdirnamermakedirssqlite3connectRow row_factoryexecute)parentconns 2/home/longshao/multi-rider-rag/shared/db/sqlite.py_connectras W__^ , ,F + FT**** ?>2 6 6 6D{DLL*+++LL,---LL,--- Kr_ table_namecp|d|d}d|DS)NzPRAGMA table_info()ch|] }|d S)r&.0rows r` z$_existing_columns..s ( ( (CCK ( ( (rb)r]fetchall)r_rcrowss r`_existing_columnsrns? <<:Z::: ; ; D D F FD ( (4 ( ( ((rbjobcd|vr-t|dtrd|dDSd|vr-t|dtrd|dDS|dr |dgSgS)N zip_partscg|]A}t|t|d,|dBS)rV) isinstancedictget)riparts r` z&_extract_zip_paths..sZ   $%% +/((6*:*: HHV     rb zip_pathscg|]}||SrgrgrirVs r`rwz&_extract_zip_paths..s:::T::::rbzip_path)rslistru)ros r`_extract_zip_pathsr}scj[)94@@  K(    cj[)94@@::[!1:::: wwz!J  IrbrjcdSfdtD} tj|dpd}n#t$rg}YnwxYw tj|dpd}n#t$ri}YnwxYw||d<d|D|d<t |d kr|d nd|d <||d <|S) Nc"i|] }|| Srgrgricolumnrjs r` z_row_to_job..s 9 9 9663v; 9 9 9rbr[]r#{}rxcRg|]$}|tj|d%S))rVr&)rUrVbasenamerzs r`rwz_row_to_job..s0]]]4rw/?/?/E/EFF]]]rbrqrr{identity_summary) JOB_COLUMNSjsonloadsru Exceptionlen)rjrorxrs` r` _row_to_jobrs {t 9 9 9 9[ 9 9 9CJsww'788@DAA  :cgg.E&F&F&N$OO !C ]]S\]]]C &))nn&9&9illtC O.C J#)A AA)B BBcdSfdtD} tj|dpd}n#t$rg}YnwxYw||d<|S)Nc"i|] }|| Srgrgrs r`rz#_row_to_dataset..sAAAvvs6{AAArbr(r class_names)DATASET_COLUMNSrrrur)rjdatasetrs` r`_row_to_datasetrs {tAAAAAAAGj-?!@!@!HDII  )GM Ns)A AAc2dSfdtDS)Nc"i|] }|| Srgrgrs r`rz)_row_to_dataset_asset..s D D DFFCK D D Drb)DATASET_ASSET_COLUMNSrjs`r`_row_to_dataset_assetrs( {t D D D D.C D D DDrbc2dSfdtDS)Nc"i|] }|| Srgrgrs r`rz%_row_to_train_job..s @ @ @FFCK @ @ @rb)TRAIN_JOB_COLUMNSrs`r`_row_to_train_jobrs( {t @ @ @ @.? @ @ @@rbc2dSfdtDS)Nc"i|] }|| Srgrgrs r`rz-_row_to_auto_annotate_job..s H H HFFCK H H Hrb)AUTO_ANNOTATE_JOB_COLUMNSrs`r`_row_to_auto_annotate_jobrs( {t H H H H.G H H HHrbcdSfdtD} tj|dpd}n#t$ri}YnwxYw tj|dpd}n#t$ri}YnwxYw||d<||d<|dd|dd|S)Nc"i|] }|| Srgrgrs r`rz,_row_to_face_library_job..s F F F663v; F F FrbrNrrOresultlibrary)FACE_LIBRARY_JOB_COLUMNSrrrurpop)rjrorrs` r`_row_to_face_library_jobrs {t F F F F-E F F FCCGGM22:d;; *SWW^44<== CMC NGGM4   GGND!!! JrcFt5}|dt|d}d|vr|dd|vr|dd|vr|dd |vr|d d |vr|d d |vr|dd|vr|dd|vr|dd|vr|dd|vr|dd|vr|dd|vr|d|d|d|d|d|dt|d }d!|vr|d"d#|vr|d$d%|vr|d&d'|vr|d(d)|vr|d*d+|vr|d,d-|vr|d.d/|vr|d0d1|vr|d2d3|vr|d4|d5|d6t|d7}d8|vr|d9d |vr|d:d;|vr|d<d=|vr|d>d?|vr|d@dA|vr|dBdC|vr|dDdE|vr|dFd1|vr|dG|dH|dIt|dJ}dK|vr|dLd%|vr|dMdN|vr|dOdP|vr|dQdR|vr|dSdT|vr|dUdV|vr|dWdX|vr|dYdZ|vr|d[d\|vr|d]d^|vr|d_d`|vr|dadb|vr|dcdd|vr|ded1|vr|dfdg|vr|dhdi|vr|djd|vr|dkdl|vr|dm|dn|do|dp|dqt|dr}dK|vr|dsd%|vr|dtdN|vr|dud|vr|dvdw|vr|dxdX|vr|dydz|vr|d{d||vr|d}d~|vr|dd|vr|dd|vr|dd|vr|dd|vr|dd|vr|dd1|vr|ddg|vr|ddi|vr|dd|vr|ddl|vr|d|d|d|d|dt|d}d|vr|dd%|vr|ddN|vr|dd|vr|dd|vr|dd|vr|dd1|vr|ddg|vr|ddi|vr|dd|vr|dd|vr|dd|vr|d|d|d|d|d|d|d|d|d|d|d|d|d|dddlm}|||ddddS#1swxYwYdS)Na CREATE TABLE IF NOT EXISTS jobs ( id TEXT PRIMARY KEY, job_type TEXT NOT NULL DEFAULT 'oracle', source_name TEXT, source_type TEXT, source_path TEXT, temp_dir TEXT, frame_interval INTEGER, status TEXT NOT NULL, message TEXT, total INTEGER NOT NULL DEFAULT 0, processed INTEGER NOT NULL DEFAULT 0, kept INTEGER NOT NULL DEFAULT 0, notfound INTEGER NOT NULL DEFAULT 0, failed INTEGER NOT NULL DEFAULT 0, downloaded INTEGER NOT NULL DEFAULT 0, start_ts INTEGER, end_ts INTEGER, owner_key TEXT, owner_ip TEXT, conf_thresh REAL, batch_size INTEGER, imgsz INTEGER, classes_raw TEXT, model_key TEXT NOT NULL DEFAULT 'general', zip_paths_json TEXT, result_dir TEXT, result_manifest_path TEXT, identity_result_path TEXT, identity_summary_json TEXT, summary_text TEXT ) jobsrzEALTER TABLE jobs ADD COLUMN model_key TEXT NOT NULL DEFAULT 'general'rzCALTER TABLE jobs ADD COLUMN job_type TEXT NOT NULL DEFAULT 'oracle'r z,ALTER TABLE jobs ADD COLUMN source_name TEXTr z,ALTER TABLE jobs ADD COLUMN source_type TEXTr z,ALTER TABLE jobs ADD COLUMN source_path TEXTr z)ALTER TABLE jobs ADD COLUMN temp_dir TEXTr z2ALTER TABLE jobs ADD COLUMN frame_interval INTEGERrz*ALTER TABLE jobs ADD COLUMN owner_key TEXTr z+ALTER TABLE jobs ADD COLUMN result_dir TEXTr!z5ALTER TABLE jobs ADD COLUMN result_manifest_path TEXTr"z5ALTER TABLE jobs ADD COLUMN identity_result_path TEXTr#z6ALTER TABLE jobs ADD COLUMN identity_summary_json TEXTzXCREATE INDEX IF NOT EXISTS idx_jobs_owner_key_start_ts ON jobs(owner_key, start_ts DESC)zSCREATE INDEX IF NOT EXISTS idx_jobs_owner_start_ts ON jobs(owner_ip, start_ts DESC)z:CREATE INDEX IF NOT EXISTS idx_jobs_end_ts ON jobs(end_ts)z:CREATE INDEX IF NOT EXISTS idx_jobs_status ON jobs(status)a CREATE TABLE IF NOT EXISTS datasets ( id TEXT PRIMARY KEY, name TEXT NOT NULL, notes TEXT NOT NULL DEFAULT '', class_names_json TEXT NOT NULL DEFAULT '[]', status TEXT NOT NULL DEFAULT 'draft', image_count INTEGER NOT NULL DEFAULT 0, labeled_count INTEGER NOT NULL DEFAULT 0, reviewed_count INTEGER NOT NULL DEFAULT 0, version_count INTEGER NOT NULL DEFAULT 0, root_dir TEXT NOT NULL, created_ts INTEGER NOT NULL, updated_ts INTEGER NOT NULL ) datasetsr'z>ALTER TABLE datasets ADD COLUMN notes TEXT NOT NULL DEFAULT ''r(zKALTER TABLE datasets ADD COLUMN class_names_json TEXT NOT NULL DEFAULT '[]'rzDALTER TABLE datasets ADD COLUMN status TEXT NOT NULL DEFAULT 'draft'r)zFALTER TABLE datasets ADD COLUMN image_count INTEGER NOT NULL DEFAULT 0r*zHALTER TABLE datasets ADD COLUMN labeled_count INTEGER NOT NULL DEFAULT 0r+zIALTER TABLE datasets ADD COLUMN reviewed_count INTEGER NOT NULL DEFAULT 0r,zHALTER TABLE datasets ADD COLUMN version_count INTEGER NOT NULL DEFAULT 0r-zAALTER TABLE datasets ADD COLUMN root_dir TEXT NOT NULL DEFAULT ''r.zEALTER TABLE datasets ADD COLUMN created_ts INTEGER NOT NULL DEFAULT 0r/zEALTER TABLE datasets ADD COLUMN updated_ts INTEGER NOT NULL DEFAULT 0zOCREATE INDEX IF NOT EXISTS idx_datasets_updated_ts ON datasets(updated_ts DESC)a CREATE TABLE IF NOT EXISTS dataset_assets ( id TEXT PRIMARY KEY, dataset_id TEXT NOT NULL, filename TEXT NOT NULL, origin_name TEXT NOT NULL, source_type TEXT NOT NULL DEFAULT 'zip', source_job_id TEXT NOT NULL DEFAULT '', source_asset_id TEXT NOT NULL DEFAULT '', file_path TEXT NOT NULL, width INTEGER NOT NULL DEFAULT 0, height INTEGER NOT NULL DEFAULT 0, size_bytes INTEGER NOT NULL DEFAULT 0, created_ts INTEGER NOT NULL, FOREIGN KEY(dataset_id) REFERENCES datasets(id) ) dataset_assetsr3zJALTER TABLE dataset_assets ADD COLUMN origin_name TEXT NOT NULL DEFAULT ''zMALTER TABLE dataset_assets ADD COLUMN source_type TEXT NOT NULL DEFAULT 'zip'r4zLALTER TABLE dataset_assets ADD COLUMN source_job_id TEXT NOT NULL DEFAULT ''r5zNALTER TABLE dataset_assets ADD COLUMN source_asset_id TEXT NOT NULL DEFAULT ''r6zHALTER TABLE dataset_assets ADD COLUMN file_path TEXT NOT NULL DEFAULT ''r7zFALTER TABLE dataset_assets ADD COLUMN width INTEGER NOT NULL DEFAULT 0r8zGALTER TABLE dataset_assets ADD COLUMN height INTEGER NOT NULL DEFAULT 0r9zKALTER TABLE dataset_assets ADD COLUMN size_bytes INTEGER NOT NULL DEFAULT 0zKALTER TABLE dataset_assets ADD COLUMN created_ts INTEGER NOT NULL DEFAULT 0zoCREATE INDEX IF NOT EXISTS idx_dataset_assets_dataset_created_ts ON dataset_assets(dataset_id, created_ts DESC)a CREATE TABLE IF NOT EXISTS train_jobs ( id TEXT PRIMARY KEY, dataset_id TEXT NOT NULL, dataset_name TEXT NOT NULL, status TEXT NOT NULL, message TEXT NOT NULL DEFAULT '', base_model TEXT NOT NULL, base_model_path TEXT NOT NULL, preset_key TEXT NOT NULL, epochs INTEGER NOT NULL DEFAULT 0, imgsz INTEGER NOT NULL DEFAULT 0, batch_size INTEGER NOT NULL DEFAULT 0, confirmed_only INTEGER NOT NULL DEFAULT 0, run_dir TEXT NOT NULL, log_path TEXT NOT NULL, manifest_path TEXT NOT NULL, artifact_dir TEXT NOT NULL, created_ts INTEGER NOT NULL, start_ts INTEGER, end_ts INTEGER, owner_key TEXT, owner_ip TEXT ) train_jobsr:zGALTER TABLE train_jobs ADD COLUMN dataset_name TEXT NOT NULL DEFAULT ''zGALTER TABLE train_jobs ADD COLUMN status TEXT NOT NULL DEFAULT 'queued'rzBALTER TABLE train_jobs ADD COLUMN message TEXT NOT NULL DEFAULT ''r;zEALTER TABLE train_jobs ADD COLUMN base_model TEXT NOT NULL DEFAULT ''r<zJALTER TABLE train_jobs ADD COLUMN base_model_path TEXT NOT NULL DEFAULT ''r=zJALTER TABLE train_jobs ADD COLUMN preset_key TEXT NOT NULL DEFAULT 'quick'r>zCALTER TABLE train_jobs ADD COLUMN epochs INTEGER NOT NULL DEFAULT 0rzBALTER TABLE train_jobs ADD COLUMN imgsz INTEGER NOT NULL DEFAULT 0rzGALTER TABLE train_jobs ADD COLUMN batch_size INTEGER NOT NULL DEFAULT 0r?zKALTER TABLE train_jobs ADD COLUMN confirmed_only INTEGER NOT NULL DEFAULT 0r@zBALTER TABLE train_jobs ADD COLUMN run_dir TEXT NOT NULL DEFAULT ''rAzCALTER TABLE train_jobs ADD COLUMN log_path TEXT NOT NULL DEFAULT ''rBzHALTER TABLE train_jobs ADD COLUMN manifest_path TEXT NOT NULL DEFAULT ''rCzGALTER TABLE train_jobs ADD COLUMN artifact_dir TEXT NOT NULL DEFAULT ''zGALTER TABLE train_jobs ADD COLUMN created_ts INTEGER NOT NULL DEFAULT 0rz2ALTER TABLE train_jobs ADD COLUMN start_ts INTEGERrz0ALTER TABLE train_jobs ADD COLUMN end_ts INTEGERz0ALTER TABLE train_jobs ADD COLUMN owner_key TEXTrz/ALTER TABLE train_jobs ADD COLUMN owner_ip TEXTzhCREATE INDEX IF NOT EXISTS idx_train_jobs_owner_key_created_ts ON train_jobs(owner_key, created_ts DESC)zfCREATE INDEX IF NOT EXISTS idx_train_jobs_owner_ip_created_ts ON train_jobs(owner_ip, created_ts DESC)zFCREATE INDEX IF NOT EXISTS idx_train_jobs_status ON train_jobs(status)a% CREATE TABLE IF NOT EXISTS auto_annotate_jobs ( id TEXT PRIMARY KEY, dataset_id TEXT NOT NULL, dataset_name TEXT NOT NULL, status TEXT NOT NULL, message TEXT NOT NULL DEFAULT '', model_key TEXT NOT NULL, conf_thresh REAL NOT NULL DEFAULT 0.25, imgsz INTEGER NOT NULL DEFAULT 640, prompt_classes TEXT NOT NULL DEFAULT '', class_mapping TEXT NOT NULL DEFAULT '', overwrite INTEGER NOT NULL DEFAULT 0, total INTEGER NOT NULL DEFAULT 0, processed INTEGER NOT NULL DEFAULT 0, updated INTEGER NOT NULL DEFAULT 0, skipped_existing INTEGER NOT NULL DEFAULT 0, no_detection INTEGER NOT NULL DEFAULT 0, created_ts INTEGER NOT NULL, start_ts INTEGER, end_ts INTEGER, owner_key TEXT, owner_ip TEXT ) auto_annotate_jobszOALTER TABLE auto_annotate_jobs ADD COLUMN dataset_name TEXT NOT NULL DEFAULT ''zOALTER TABLE auto_annotate_jobs ADD COLUMN status TEXT NOT NULL DEFAULT 'queued'zJALTER TABLE auto_annotate_jobs ADD COLUMN message TEXT NOT NULL DEFAULT ''zLALTER TABLE auto_annotate_jobs ADD COLUMN model_key TEXT NOT NULL DEFAULT ''rzPALTER TABLE auto_annotate_jobs ADD COLUMN conf_thresh REAL NOT NULL DEFAULT 0.25zLALTER TABLE auto_annotate_jobs ADD COLUMN imgsz INTEGER NOT NULL DEFAULT 640rDzQALTER TABLE auto_annotate_jobs ADD COLUMN prompt_classes TEXT NOT NULL DEFAULT ''rEzPALTER TABLE auto_annotate_jobs ADD COLUMN class_mapping TEXT NOT NULL DEFAULT ''rFzNALTER TABLE auto_annotate_jobs ADD COLUMN overwrite INTEGER NOT NULL DEFAULT 0rzJALTER TABLE auto_annotate_jobs ADD COLUMN total INTEGER NOT NULL DEFAULT 0rzNALTER TABLE auto_annotate_jobs ADD COLUMN processed INTEGER NOT NULL DEFAULT 0rGzLALTER TABLE auto_annotate_jobs ADD COLUMN updated INTEGER NOT NULL DEFAULT 0rHzUALTER TABLE auto_annotate_jobs ADD COLUMN skipped_existing INTEGER NOT NULL DEFAULT 0rIzQALTER TABLE auto_annotate_jobs ADD COLUMN no_detection INTEGER NOT NULL DEFAULT 0zOALTER TABLE auto_annotate_jobs ADD COLUMN created_ts INTEGER NOT NULL DEFAULT 0z:ALTER TABLE auto_annotate_jobs ADD COLUMN start_ts INTEGERz8ALTER TABLE auto_annotate_jobs ADD COLUMN end_ts INTEGERz8ALTER TABLE auto_annotate_jobs ADD COLUMN owner_key TEXTz7ALTER TABLE auto_annotate_jobs ADD COLUMN owner_ip TEXTzxCREATE INDEX IF NOT EXISTS idx_auto_annotate_jobs_owner_key_created_ts ON auto_annotate_jobs(owner_key, created_ts DESC)zvCREATE INDEX IF NOT EXISTS idx_auto_annotate_jobs_owner_ip_created_ts ON auto_annotate_jobs(owner_ip, created_ts DESC)zVCREATE INDEX IF NOT EXISTS idx_auto_annotate_jobs_status ON auto_annotate_jobs(status)a CREATE TABLE IF NOT EXISTS face_library_jobs ( id TEXT PRIMARY KEY, action TEXT NOT NULL, status TEXT NOT NULL DEFAULT 'queued', message TEXT NOT NULL DEFAULT '', stage TEXT NOT NULL DEFAULT '', processed INTEGER NOT NULL DEFAULT 0, total INTEGER NOT NULL DEFAULT 0, created_ts INTEGER NOT NULL DEFAULT 0, start_ts INTEGER, end_ts INTEGER, error TEXT NOT NULL DEFAULT '', result_json TEXT NOT NULL DEFAULT '{}', library_json TEXT NOT NULL DEFAULT '{}' ) face_library_jobsrKzOALTER TABLE face_library_jobs ADD COLUMN action TEXT NOT NULL DEFAULT 'rebuild'zNALTER TABLE face_library_jobs ADD COLUMN status TEXT NOT NULL DEFAULT 'queued'zIALTER TABLE face_library_jobs ADD COLUMN message TEXT NOT NULL DEFAULT ''rLzGALTER TABLE face_library_jobs ADD COLUMN stage TEXT NOT NULL DEFAULT ''zMALTER TABLE face_library_jobs ADD COLUMN processed INTEGER NOT NULL DEFAULT 0zIALTER TABLE face_library_jobs ADD COLUMN total INTEGER NOT NULL DEFAULT 0zNALTER TABLE face_library_jobs ADD COLUMN created_ts INTEGER NOT NULL DEFAULT 0z9ALTER TABLE face_library_jobs ADD COLUMN start_ts INTEGERz7ALTER TABLE face_library_jobs ADD COLUMN end_ts INTEGERrMzGALTER TABLE face_library_jobs ADD COLUMN error TEXT NOT NULL DEFAULT ''rNzOALTER TABLE face_library_jobs ADD COLUMN result_json TEXT NOT NULL DEFAULT '{}'rOzPALTER TABLE face_library_jobs ADD COLUMN library_json TEXT NOT NULL DEFAULT '{}'zTCREATE INDEX IF NOT EXISTS idx_face_library_jobs_status ON face_library_jobs(status)zaCREATE INDEX IF NOT EXISTS idx_face_library_jobs_created_ts ON face_library_jobs(created_ts DESC)a CREATE TABLE IF NOT EXISTS dispatch_auth_sessions ( owner_key TEXT PRIMARY KEY, owner_ip TEXT, username TEXT NOT NULL DEFAULT '', access_token TEXT NOT NULL DEFAULT '', refresh_token TEXT NOT NULL DEFAULT '', token_type TEXT NOT NULL DEFAULT 'Bearer', expires_in INTEGER NOT NULL DEFAULT 0, expires_at INTEGER, authenticated_ts INTEGER, updated_ts INTEGER NOT NULL DEFAULT 0, status TEXT NOT NULL DEFAULT 'pending', is_mock INTEGER NOT NULL DEFAULT 0, last_error TEXT NOT NULL DEFAULT '' ) zuCREATE INDEX IF NOT EXISTS idx_dispatch_auth_owner_ip_updated_ts ON dispatch_auth_sessions(owner_ip, updated_ts DESC)a" CREATE TABLE IF NOT EXISTS dispatch_queue ( id TEXT PRIMARY KEY, owner_key TEXT, owner_ip TEXT, source_job_id TEXT NOT NULL DEFAULT '', source_asset_id TEXT NOT NULL DEFAULT '', source_job_type TEXT NOT NULL DEFAULT '', source_name TEXT NOT NULL DEFAULT '', source_type TEXT NOT NULL DEFAULT '', asset_name TEXT NOT NULL DEFAULT '', face_index INTEGER NOT NULL DEFAULT 0, person_name TEXT NOT NULL DEFAULT '', person_id_no TEXT NOT NULL DEFAULT '', person_phone TEXT NOT NULL DEFAULT '', similarity_score REAL NOT NULL DEFAULT 0, illegal_type TEXT NOT NULL DEFAULT '', sssj_dm TEXT NOT NULL DEFAULT '', sssj_mc TEXT NOT NULL DEFAULT '', ssfj_dm TEXT NOT NULL DEFAULT '', ssfj_mc TEXT NOT NULL DEFAULT '', zbpcs_dm TEXT NOT NULL DEFAULT '', zbpcs_mc TEXT NOT NULL DEFAULT '', dzmc TEXT NOT NULL DEFAULT '', rwdyid TEXT NOT NULL DEFAULT '', sjcsly TEXT NOT NULL DEFAULT '', dispatch_status TEXT NOT NULL DEFAULT 'pending', sms_status TEXT NOT NULL DEFAULT 'pending', last_error TEXT NOT NULL DEFAULT '', draft_payload_json TEXT NOT NULL DEFAULT '', identity_payload_json TEXT NOT NULL DEFAULT '', dispatch_response_json TEXT NOT NULL DEFAULT '', sms_preview TEXT NOT NULL DEFAULT '', created_ts INTEGER NOT NULL DEFAULT 0, updated_ts INTEGER NOT NULL DEFAULT 0 ) zlCREATE INDEX IF NOT EXISTS idx_dispatch_queue_owner_created_ts ON dispatch_queue(owner_key, created_ts DESC)znCREATE INDEX IF NOT EXISTS idx_dispatch_queue_owner_ip_created_ts ON dispatch_queue(owner_ip, created_ts DESC)zCREATE UNIQUE INDEX IF NOT EXISTS idx_dispatch_queue_owner_source_face_person ON dispatch_queue(owner_key, source_job_id, source_asset_id, face_index, person_id_no)zWCREATE INDEX IF NOT EXISTS idx_dispatch_queue_status ON dispatch_queue(dispatch_status)a CREATE TABLE IF NOT EXISTS dispatch_records ( id TEXT PRIMARY KEY, queue_id TEXT NOT NULL, owner_key TEXT, owner_ip TEXT, status TEXT NOT NULL DEFAULT 'pending', request_payload_json TEXT NOT NULL DEFAULT '', response_payload_json TEXT NOT NULL DEFAULT '', error_message TEXT NOT NULL DEFAULT '', created_ts INTEGER NOT NULL DEFAULT 0 ) zpCREATE INDEX IF NOT EXISTS idx_dispatch_records_owner_created_ts ON dispatch_records(owner_key, created_ts DESC)am CREATE TABLE IF NOT EXISTS dispatch_sms_records ( id TEXT PRIMARY KEY, queue_id TEXT NOT NULL, owner_key TEXT, owner_ip TEXT, mobile TEXT NOT NULL DEFAULT '', content TEXT NOT NULL DEFAULT '', status TEXT NOT NULL DEFAULT 'pending', request_payload_json TEXT NOT NULL DEFAULT '', response_payload_json TEXT NOT NULL DEFAULT '', error_message TEXT NOT NULL DEFAULT '', created_ts INTEGER NOT NULL DEFAULT 0 ) zxCREATE INDEX IF NOT EXISTS idx_dispatch_sms_records_owner_created_ts ON dispatch_sms_records(owner_key, created_ts DESC)r)init_task_queue_table)rar]rnshared.task_queuercommit)r_columnsdataset_columns asset_columns train_columns auto_columnsface_library_columnsrs r`init_dbrs et ! # # # J$D&11 g % % LLW    W $ $ LL^ _ _ _  ' ' LLG H H H  ' ' LLG H H H  ' ' LLG H H H W $ $ LLD E E E 7 * * LLM N N N g % % LLE F F F w & & LLF G G G ! 0 0 LLP Q Q Q ! 0 0 LLP Q Q Q "' 1 1 LLQ R R R f    a    QRRR QRRR     &,D*== / ) ) LLY Z Z Z _ 4 4 LL]    ? * * LL_ ` ` `  / / LLa b b b / 1 1 LLc d d d ? 2 2 LLd e e e / 1 1 LLc d d d _ , , LL\ ] ] ]  . . LL` a a a  . . LL` a a a fggg     (*$0@AA  - - LLe f f f  - - LLh i i i - / / LLg h h h M 1 1 LLi j j j m + + LLc d d d - ' ' LLa b b b = ( ( LLb c c c } , , LLf g g g } , , LLf g g g }        8*$ ==  . . LLb c c c = ( ( LLb c c c M ) ) LL] ^ ^ ^ } , , LL` a a a M 1 1 LLe f f f } , , LLe f f f = ( ( LL^ _ _ _ - ' ' LL] ^ ^ ^ } , , LLb c c c = 0 0 LLf g g g M ) ) LL] ^ ^ ^ ] * * LL^ _ _ _ - / / LLc d d d  . . LLb c c c } , , LLb c c c ] * * LLM N N N = ( ( LLK L L L m + + LLK L L L ] * * LLJ K K K v    t    ]^^^     8)/CDD  - - LLj k k k < ' ' LLj k k k L ( ( LLe f f f l * * LLg h h h  , , LLk l l l , & & LLg h h h < / / LLl m m m , . . LLk l l l l * * LLi j j j , & & LLe f f f l * * LLi j j j L ( ( LLg h h h \ 1 1 LLp q q q  - - LLl m m m | + + LLj k k k \ ) ) LLU V V V < ' ' LLS T T T l * * LLS T T T \ ) ) LLR S S S  G     E    mnnn     ( 17JKK / / / LLj k k k / / / LLi j j j 0 0 0 LLd e e e . . . LLb c c c 2 2 2 LLh i i i . . . LLd e e e 3 3 3 LLi j j j 1 1 1 LLT U U U / / / LLR S S S . . . LLb c c c  4 4 4 LLj k k k !5 5 5 LLk l l l klll o        &  D    $ & & & N z    |     s    e         ~        "  G    <;;;;;d### Keeeeeeeeeeeeeeeeeesk:lllct|}id|ddd|ddd|ddd|ddd|ddd|ddd |d d |d dd |d dd t|d pd dt|dpd dt|dpd dt|dpd dt|dpd dt|dpd d|dd|d|dd|dd|d|d|d|dd|dtt j|d|dd|dd|d dt j|d!pid|d"dd# }t 5}|d$||ddddS#1swxYwYdS)%Nroraclerr r r r r rrrrrrrrrrrrrrrrrrF ensure_asciir r!r"rr$) rrrrrrrrr r!r"r#r$a INSERT INTO jobs ( job_type, id, source_name, source_type, source_path, temp_dir, frame_interval, status, message, total, processed, kept, notfound, failed, downloaded, start_ts, end_ts, owner_key, owner_ip, conf_thresh, batch_size, imgsz, classes_raw, model_key, zip_paths_json, result_dir, result_manifest_path, identity_result_path, identity_summary_json, summary_text ) VALUES ( :job_type, :id, :source_name, :source_type, :source_path, :temp_dir, :frame_interval, :status, :message, :total, :processed, :kept, :notfound, :failed, :downloaded, :start_ts, :end_ts, :owner_key, :owner_ip, :conf_thresh, :batch_size, :imgsz, :classes_raw, :model_key, :zip_paths_json, :result_dir, :result_manifest_path, :identity_result_path, :identity_summary_json, :summary_text ) ON CONFLICT(id) DO UPDATE SET job_type = excluded.job_type, source_name = excluded.source_name, source_type = excluded.source_type, source_path = excluded.source_path, temp_dir = excluded.temp_dir, frame_interval = excluded.frame_interval, status = excluded.status, message = excluded.message, total = excluded.total, processed = excluded.processed, kept = excluded.kept, notfound = excluded.notfound, failed = excluded.failed, downloaded = excluded.downloaded, start_ts = excluded.start_ts, end_ts = excluded.end_ts, owner_key = excluded.owner_key, owner_ip = excluded.owner_ip, conf_thresh = excluded.conf_thresh, batch_size = excluded.batch_size, imgsz = excluded.imgsz, classes_raw = excluded.classes_raw, model_key = excluded.model_key, zip_paths_json = excluded.zip_paths_json, result_dir = excluded.result_dir, result_manifest_path = excluded.result_manifest_path, identity_result_path = excluded.identity_result_path, identity_summary_json = excluded.identity_summary_json, summary_text = excluded.summary_text ) r}ruintrrdumpsrar]r)rorxpayloadr_s r`save_jobrs"3''ICGGJ11 cggdB sww}b11 sww}b11  sww}b11  CGGJ++  #''"233 #''(B'' 3779b)) SWWW%%*++ S--233 CGGFOO(q)) C ++0q11 #cggh'',1-- c#'',//4155 CGGJ''!" #''(###$WW["--GGJ++ww}--ggl++!!ww}b11WW[-88*YUCCCgglB// #(> C C #(> C C!%CGG4F,G,G,M2\a!b!b!b33=GB 2t - \ _0 0 0 b e222222222222222222s#+MM"Mjob_idct5}|d|f}dddn #1swxYwYt|S)NzSELECT * FROM jobs WHERE id = ?)rar]fetchonerrr_rjs r`get_jobr5s Ttll.Z! @ @ @K  rb)maxminrappendrar]rl) rrrr safe_limitqueryparamsr_rms r`list_active_jobsr;s' X QC ,,c2233J E#H-F  $$ h E MM* 6t||E6**3355666666666666666 @ @ @ @ @@s>)B33B7:B7rcx|dd|dd|ddtj|dpgd|dd t|d pd t|d pd t|d pd t|dpd |ddt|dpd t|dpd d }t 5}|d||ddddS#1swxYwYdS)Nrrr&r'rFrrdraftr)rr*r+r,r-r.r/r%a  INSERT INTO datasets ( id, name, notes, class_names_json, status, image_count, labeled_count, reviewed_count, version_count, root_dir, created_ts, updated_ts ) VALUES ( :id, :name, :notes, :class_names_json, :status, :image_count, :labeled_count, :reviewed_count, :version_count, :root_dir, :created_ts, :updated_ts ) ON CONFLICT(id) DO UPDATE SET name = excluded.name, notes = excluded.notes, class_names_json = excluded.class_names_json, status = excluded.status, image_count = excluded.image_count, labeled_count = excluded.labeled_count, reviewed_count = excluded.reviewed_count, version_count = excluded.version_count, root_dir = excluded.root_dir, created_ts = excluded.created_ts, updated_ts = excluded.updated_ts )rurrrrar]r)rrr_s r` save_datasetr]skk$## FB''Wb)) Jw{{='A'A'GRV[\\\++h007;;}55:;;W[[99>Q??gkk*:;;@qAAW[[99>Q??KK B//'++l338q99'++l338q99  G t  , /   2 5s7+F//F36F3r1ct5}|d|f}dddn #1swxYwYt|S)Nz#SELECT * FROM datasets WHERE id = ?)rar]rrr1r_rjs r` get_datasetrs \tll@:-PPYY[[\\\\\\\\\\\\\\\ 3  rassetc|dd|dd|dd|dd|dd|dd|d d|d dt|d pd t|d pd t|dpd t|dpd d }t5}|d||ddddS#1swxYwYdS)Nrrr1r2r3r zipr4r5r6r7rr8r9r.r0a INSERT INTO dataset_assets ( id, dataset_id, filename, origin_name, source_type, source_job_id, source_asset_id, file_path, width, height, size_bytes, created_ts ) VALUES ( :id, :dataset_id, :filename, :origin_name, :source_type, :source_job_id, :source_asset_id, :file_path, :width, :height, :size_bytes, :created_ts ) ON CONFLICT(id) DO UPDATE SET dataset_id = excluded.dataset_id, filename = excluded.filename, origin_name = excluded.origin_name, source_type = excluded.source_type, source_job_id = excluded.source_job_id, source_asset_id = excluded.source_asset_id, file_path = excluded.file_path, width = excluded.width, height = excluded.height, size_bytes = excluded.size_bytes, created_ts = excluded.created_ts rurrar]r)rrr_s r`save_dataset_assetrsiib!!ii b11IIj"--yy33yy66?B77 99%6;;YY{B//UYYw'',1--eii)).Q//%))L116Q77%))L116Q77  G t  , /   2 5s+E>>FFct5}|d|f}dddn #1swxYwYt||dndS)NzASELECT COUNT(*) AS total FROM dataset_assets WHERE dataset_id = ?rr)rar]rrrs r`count_dataset_assetsrs tll O M   (**  ss7||A 6 66rdctdtt|pdd}t5}|d||f}dddn #1swxYwYd|DS)Nrrz SELECT * FROM dataset_assets WHERE dataset_id = ? ORDER BY created_ts DESC, id DESC LIMIT ? c0g|]}|t|Sr)rrhs r`rwz'list_dataset_assets..s" J J J3#/ !# & &///rbrrrrar]rl)r1rrr_rms r`list_dataset_assetsrsQC --s3344J  t||  $    (**                 K J$ J J JJs+A33A7:A7asset_idct5}|d||f}dddn #1swxYwYt|S)Nz SELECT * FROM dataset_assets WHERE dataset_id = ? AND id = ? LIMIT 1 )rar]rr)r1rr_rjs r`get_dataset_assetrs  tll   "   (**                 ! % %%s+AA  A ctdtt|pdd}t5}|d|f}dddn #1swxYwYd|DS)Nrrrz SELECT * FROM datasets ORDER BY updated_ts DESC, created_ts DESC, id DESC LIMIT ? c0g|]}|t|Sr)rrhs r`rwz!list_datasets..s! D D DSCOOC OOOrbrrrr_rms r` list_datasetsrsQC --s3344J  t||  M   (**                 E DD D D DD*A22A69A6cid|ddd|ddd|ddd|ddd|ddd|ddd |d dd |d d d t|d pd dt|dpd dt|dpd d|drdnd d|ddd|ddd|ddd|dddt|dpd |d|d|dd|ddd}t5}|d||ddddS#1swxYwYdS)Nrrr1r:rqueuedrr;r<r=quickr>rrrr?rr@rArBrCr.rrrrrrrra INSERT INTO train_jobs ( id, dataset_id, dataset_name, status, message, base_model, base_model_path, preset_key, epochs, imgsz, batch_size, confirmed_only, run_dir, log_path, manifest_path, artifact_dir, created_ts, start_ts, end_ts, owner_key, owner_ip ) VALUES ( :id, :dataset_id, :dataset_name, :status, :message, :base_model, :base_model_path, :preset_key, :epochs, :imgsz, :batch_size, :confirmed_only, :run_dir, :log_path, :manifest_path, :artifact_dir, :created_ts, :start_ts, :end_ts, :owner_key, :owner_ip ) ON CONFLICT(id) DO UPDATE SET dataset_id = excluded.dataset_id, dataset_name = excluded.dataset_name, status = excluded.status, message = excluded.message, base_model = excluded.base_model, base_model_path = excluded.base_model_path, preset_key = excluded.preset_key, epochs = excluded.epochs, imgsz = excluded.imgsz, batch_size = excluded.batch_size, confirmed_only = excluded.confirmed_only, run_dir = excluded.run_dir, log_path = excluded.log_path, manifest_path = excluded.manifest_path, artifact_dir = excluded.artifact_dir, created_ts = excluded.created_ts, start_ts = excluded.start_ts, end_ts = excluded.end_ts, owner_key = excluded.owner_key, owner_ip = excluded.owner_ip rrorr_s r`save_train_jobrs cggdBcgglB// 33 #''(H--  3779b))  cgglB//  377#4b99 cgglG44 #cggh'',1-- SWWW%%*++ c#'',//4155 sww'788?!!a 3779b)) CGGJ++ "55 33!" c#'',//4155#$GGJ''''(##WW["--GGJ+++G0 %t  B E# # # H K%%%%%%%%%%%%%%%%%%s(+I  I$'I$ct5}|d|f}dddn #1swxYwYt|S)Nz%SELECT * FROM train_jobs WHERE id = ?)rar]rrrs r` get_train_jobr4s ZtllBVINNWWYYZZZZZZZZZZZZZZZ S ! !!rc"|s|sgStdtt|pdd}t5}|d|||f}dddn #1swxYwYd|DS)Nrrrz SELECT * FROM train_jobs WHERE owner_key = ? OR (COALESCE(owner_key, '') = '' AND owner_ip = ?) ORDER BY created_ts DESC, id DESC LIMIT ? c0g|]}|t|Sr)rrhs r`rwz#list_train_jobs..Ks" F F Fsco c " "ooorbrrrrrr_rms r`list_train_jobsr:s X QC ,,c2233J  t|| * -    (**                 G Fd F F FF,A::A>A>cJid|ddd|ddd|ddd|ddd|ddd|ddd t|d pd d t|d pd d |d dd|ddd|drdnddt|dpddt|dpddt|dpddt|dpddt|dpddt|dpd|d|d|dd|ddd}t5}|d||ddddS#1swxYwYdS)Nrrr1r:rrrrrg?rirDrErFrrrrrGrHrIr.rrrrra INSERT INTO auto_annotate_jobs ( id, dataset_id, dataset_name, status, message, model_key, conf_thresh, imgsz, prompt_classes, class_mapping, overwrite, total, processed, updated, skipped_existing, no_detection, created_ts, start_ts, end_ts, owner_key, owner_ip ) VALUES ( :id, :dataset_id, :dataset_name, :status, :message, :model_key, :conf_thresh, :imgsz, :prompt_classes, :class_mapping, :overwrite, :total, :processed, :updated, :skipped_existing, :no_detection, :created_ts, :start_ts, :end_ts, :owner_key, :owner_ip ) ON CONFLICT(id) DO UPDATE SET dataset_id = excluded.dataset_id, dataset_name = excluded.dataset_name, status = excluded.status, message = excluded.message, model_key = excluded.model_key, conf_thresh = excluded.conf_thresh, imgsz = excluded.imgsz, prompt_classes = excluded.prompt_classes, class_mapping = excluded.class_mapping, overwrite = excluded.overwrite, total = excluded.total, processed = excluded.processed, updated = excluded.updated, skipped_existing = excluded.skipped_existing, no_detection = excluded.no_detection, created_ts = excluded.created_ts, start_ts = excluded.start_ts, end_ts = excluded.end_ts, owner_key = excluded.owner_key, owner_ip = excluded.owner_ip )rufloatrrar]rrs r`save_auto_annotate_jobrNs cggdBcgglB// 33 #''(H--  3779b))  SWW["--  uSWW]33;t<< SWWW%%,-- #''"2B77 "55 #''+..5QQA SWWW%%*++ S--233 3swwy)).Q// C(: ; ; @qAA CGGN338q99!" c#'',//4155#$GGJ''''(##WW["--GGJ+++G0 %t  B E# # # H K%%%%%%%%%%%%%%%%%%s +JJJct5}|d|f}dddn #1swxYwYt|S)Nz-SELECT * FROM auto_annotate_jobs WHERE id = ?)rar]rrrs r`get_auto_annotate_jobrs btllJVIVV__aabbbbbbbbbbbbbbb $S ) ))rc"|s|sgStdtt|pdd}t5}|d|||f}dddn #1swxYwYd|DS)Nrrrz SELECT * FROM auto_annotate_jobs WHERE owner_key = ? OR (COALESCE(owner_key, '') = '' AND owner_ip = ?) ORDER BY created_ts DESC, id DESC LIMIT ? c0g|]}|t|Sr)rrhs r`rwz+list_auto_annotate_jobs..s" N N Nsco %c * *ooorbrrs r`list_auto_annotate_jobsrs X QC ,,c2233J  t|| * -    (**                 O Nd N N NNrc|dd|dd|dd|dd|ddt|d pd t|d pd t|d p|d pd |d |d|ddtj|dpidtj|dpidd }t 5}|d||ddddS#1swxYwYdS)NrrrKrebuildrrrrLrrrr.rrrMrFrrrJa INSERT INTO face_library_jobs ( id, action, status, message, stage, processed, total, created_ts, start_ts, end_ts, error, result_json, library_json ) VALUES ( :id, :action, :status, :message, :stage, :processed, :total, :created_ts, :start_ts, :end_ts, :error, :result_json, :library_json ) ON CONFLICT(id) DO UPDATE SET action = excluded.action, status = excluded.status, message = excluded.message, stage = excluded.stage, processed = excluded.processed, total = excluded.total, created_ts = excluded.created_ts, start_ts = excluded.start_ts, end_ts = excluded.end_ts, error = excluded.error, result_json = excluded.result_json, library_json = excluded.library_json )rurrrrar]rrs r`save_face_library_jobr sggdB''(I..''(H--779b))"%%--233SWWW%%*++#'',//K377:3F3FK!LLGGJ''''(##"%%z#''("3"3"9rNNN 3779#5#5#;%PPPG t  . 1   4 7s +GG Gct5}|d|f}dddn #1swxYwYt|S)Nz,SELECT * FROM face_library_jobs WHERE id = ?rar]rrrs r`get_face_library_jobrs atllIF9UU^^``aaaaaaaaaaaaaaa #C ( ((rct5}|d}dddn #1swxYwYt|S)Nz SELECT * FROM face_library_jobs WHERE status IN ('queued', 'running') ORDER BY created_ts ASC, id ASC LIMIT 1 r )r_rjs r`get_active_face_library_jobrs  tll    (**                 $C ( ((s(AA Actdtt|pdd}t5}|d|f}dddn #1swxYwYd|DS)Nrrrz SELECT * FROM face_library_jobs ORDER BY created_ts DESC, id DESC LIMIT ? c0g|]}|t|Sr)rrhs r`rwz*list_face_library_jobs..s" M M McS_ $S ) )___rbrrs r`list_face_library_jobsrsQC ,,c2233J  t||  M   (**                 N MT M M MMr2c"|s|sgStdtt|pdd}t5}|d|||f}dddn #1swxYwYd|DS)Nrrrz SELECT * FROM jobs WHERE owner_key = ? OR (COALESCE(owner_key, '') = '' AND owner_ip = ?) ORDER BY start_ts DESC LIMIT ? c0g|]}|t|Srrrhs r`rwzlist_jobs.. rrbrrs r` list_jobsrs X QC ,,c2233J  t|| * -    (**                 A @ @ @ @@rc&t|||S)N)r)r)rrrs r`list_saved_jobsrs Y 6 6 66rbctdtt|pdd}t5}|d|f}dddn #1swxYwYd|DS)Nrrrzx SELECT * FROM jobs ORDER BY start_ts DESC, id DESC LIMIT ? c0g|]}|t|Srrrhs r`rwz!list_all_jobs..rrbrrs r` list_all_jobsrsQC ,,c2233J  t||  M   (**                 A @ @ @ @@rdaysc ttjt|ddzdzdzz }t5}|d|f}g}|D].}||d tj|dpd}n#t$rg}YnwxYw|D]q}|rmtj |rN tj |9#t$rYEt$r }tjd||Yd}~id}~wwxYwr|d } | rotj | rP t%j| d n8#t$rYn,t$r }tjd | |Yd}~nd}~wwxYw|d } | rotj | rP t%j| d n8#t$rYn,t$r }tjd| |Yd}~nd}~wwxYw|d} | rptj | rQ tj | #t$rYt$r!}tjd| |Yd}~&d}~wwxYw0|r4|dd|D|dddn #1swxYwYt-|S)Nr<z SELECT id, zip_paths_json, result_dir, source_path, temp_dir FROM jobs WHERE end_ts IS NOT NULL AND end_ts < ? rrrz failed to remove zip file %s: %sr F) ignore_errorsz"failed to remove result dir %s: %sr z failed to remove temp dir %s: %sr z#failed to remove source file %s: %szDELETE FROM jobs WHERE id = ?cg|]}|fSrgrg)rirs r`rwz$cleanup_old_jobs..Ws>b>b>bVy>b>b>brb)rtimerrar]rlrrrrrUrVisfileremoveFileNotFoundErrorrwarningisdirshutilrmtree executemanyrr) rcutoffr_rm delete_idsrjrxrVexcr r r s r`cleanup_old_jobsr0"s   D! r 1B 6 ; ;F 4t||  I    (**  % \% \C   c$i ( ( (  Js+;'<'DEE      ! V VVBGNN400VV $,$VVV'I4QTUUUUUUUUV\*J ZbgmmJ77 ZZM*EBBBBB(D ZZZN#GUXYYYYYYYYZ:H VBGMM(33 VVM(%@@@@@(D VVVN#ExQTUUUUUUUUVm,K \rw~~k:: \\Ik****(D \\\N#H+WZ[[[[[[[[\     <>b>bWa>b>b>b c c c KKMMMi444444444444444l z??s A K)B32K)3 C?K)C(K)+D?K) D5 K) D5 D0 +K)0D5 5-K)#E:9K): F/K) F/F*%K)*F//,K)G32K)3 H(=K)? H(H#K)#H((,K)I+)K)+ J"5K)8 J"JK)J"";K))K-0K- job_typescttj}d|pgD}d}|g}|r=dd|D}|d|dz }||t 5}|d|d|}||jcdddS#1swxYwYdS) Ncg|]D}t|#t|ESrg)strstrip)riitems r`rwz1mark_running_jobs_interrupted.._s=[[[DTIZIZ[c$iioo''[[[rbzstatus = 'running'z, c3K|]}dVdS)?Nrg)ri_s r` z0mark_running_jobs_interrupted..cs" = = = = = = = =rbz AND job_type IN (rea< UPDATE jobs SET status = 'interrupted', end_ts = COALESCE(end_ts, ?), message = CASE WHEN message IS NULL OR message = '' THEN 'service restarted before job completed' ELSE message END WHERE z )rr$joinextendrar]rrowcount)r1nowsafe_job_typeswherer placeholdersr_cursors r`mark_running_jobs_interruptedrC]s8 dikk  C[[Y_"[[[N EF&yy = =n = = ===  5l5555 n%%% t         s5CC C)rPN)rN)r)r)r)rr);rrUrYr$r*typingrshared.config.configrrrrrrrrr Connectionrar4setrnrtr|r}r[rrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrr0rCrgrbr`rHs  FFFFFFFFFF B  00" '$    )G.)C)CH)))) DcN tCy    W[4'DcNT,A* t+ S#X0E    Ew{T1Ed38nt6KEEEE A7;-A$sCx.42GAAAA I7;#5I$sCx.4:OIIII '+"4c3h$9N*ffffRU$sCx.UTUUUUpCDcNT1 AAAA ADj A  $sCx. AAAAD*$sCx.*T****Z C DcNT$9    *d38n*****Z7S7S7777 K KC K Kd4S>>R K K K K &# & &c3h$9N & & & & E E EtDcN'; E E E E>S#X>4>>>>B"#"$sCx.4"7"""" GGsGcG#GtDQTVYQYNG[GGGG(>S#X>4>>>>B*#*$sCx.4*?**** OOsOcO#OtTXY\^aYaTbOcOOOO(,tCH~,$,,,,^))c3h$)>)))) )T#s(^d%: ) ) ) ) N N# NtDcN/C N N N NAAAACAd3PS8nAUAAAA(77s7c7#7tDQTVYQYNG[7777 A A Ad4S>&: A A A A8838s8888vT#Y-=rb