o "i@sfddlmZddlZddlmZmZmZddlmZe e Z dZ dZ dd d Zd e e fdddZdS)) annotationsN)AnyDictList)get_connection recording_urlidreturn List[str]c Cspt&}|}|dd|}Wdn1swYWdn1s,wYdd|DS)NzgSELECT TABLE_NAME FROM information_schema.TABLES WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME LIKE %s)z %_raw_callscSsg|] }|dddqS) TABLE_NAME _raw_calls)replace).0rowrC/home/aiteam/pcaa-dev/call-proccessing/stt_pipeline/db/raw_calls.py sz get_all_bids..)rcursorexecutefetchall)conncurrowsrrr get_all_bids s  rdbidstralready_seen_idslimitintid_colurl_colList[Dict[str, Any]]c Cs"|d}t_}|K}|r9ddgt|}|d|d|d|d|d|d |d g||Rn|d|d|d|d |d |f|} Wdn1s[wYWdn1sjwYg} | D]} t| } t| || d <| |d | d <| | qs| S)Nr z, z%szSELECT * FROM `z ` WHERE `z ` NOT IN (z) AND `z` IS NOT NULL AND `z` != '' ORDER BY `z` DESC LIMIT %scall_idr r) rrjoinlenrrdictrgetappend) rrrr!r"tablerr placeholdersrresultr normalisedrrr get_new_callssP      r.)r r ) rrrr rr r!rr"rr r#) __future__rloggingtypingrrr db.connectionr getLogger__name__loggerDEFAULT_RECORDING_URL_COLUMNDEFAULT_CALL_ID_COLUMNrr.rrrrs