enrich_emails.py

L33 Decision if os.path.exists('token.json') L37 Decision if creds and creds.expired and creds.refresh_token L39 Decision try/except block L42 Output print() L46 Decision if not creds L49 Decision if os.path.exists(service_account_file) L50 File I/O open() L51 File I/O json.load() L53 Decision if 'type' in content and content['type'] == 'service_account' L54 Output print() L56 Decision if 'installed' in content L57 Output print() L61 File I/O open('token.json') L71 Decision if not api_key L72 Output print() L86 Decision if full_name L88 Decision if first_name L90 Decision if last_name L94 Decision if company_domain L96 Decision if company_name L103 Decision if not has_name or not has_company L106 Decision try/except block L107 API Call requests.post() L112 Decision if data.get('email') and data.get('email_status') in ['valid', 'risky'] L118 Output print() L127 Decision if not api_key L128 Output print() L142 Decision for row in rows_data L143 Transform .append() L161 Decision try/except block L162 API Call requests.post() L167 Decision if search_id L168 Output print() L171 Output print() L175 Output print() L184 Decision if not api_key L192 Output print() L194 Decision while True L195 Decision try/except block L196 API Call requests.get() L205 Decision if status == 'completed' L206 Output print() L208 Decision if status == 'failed' L209 Output print() L211 Decision if status in ['queued', 'running'] L212 Output print() L215 Output print() L219 Output print() L228 Decision if not api_key L236 Decision try/except block L237 API Call requests.get() L242 Output print() L242 Transform len() L246 Output print() L255 Decision if not creds L256 Output print() L259 API Call gspread.authorize() L262 Decision try/except block L266 Output print() L272 Decision if not records L273 Output print() L279 Decision for (col_idx, header) in enumerate(headers) L279 Transform enumerate() L280 Decision if header.lower() == 'email' L280 Transform .lower() L284 Decision if not email_col L285 Output print() L290 Decision for (idx, record) in enumerate(records) L290 Transform enumerate() L294 Transform .strip() L295 Decision if email L299 Transform .strip() L300 Transform .strip() L301 Transform .strip() L302 Transform .strip() L303 Transform .strip() L305 Transform .append() L314 Decision if not rows_to_enrich L315 Output print() L318 Output print() L318 Transform len() L321 Decision if len(rows_to_enrich) >= 200 L321 Transform len() L322 Output print() L322 Transform len() L326 Decision if result is None L327 Output print() L331 Output print() L331 Transform len() L339 Decision if not search_id L340 Output print() L344 Decision if not poll_bulk_search_status(search_id) L345 Output print() L350 Decision if not results L351 Output print() L360 Decision for (idx, result_row) in enumerate(results[1:], start=0) L360 Transform enumerate() L361 Decision if idx >= len(rows_to_enrich) L361 Transform len() L368 Transform len() L369 Transform len() L371 Decision if email and email_status in ['valid', 'risky'] L372 Transform .append() L377 Output print() L381 Output print() L385 Decision if updates_to_apply L386 Output print() L386 Transform len() L388 Decision for update in updates_to_apply L391 Transform .append() L393 Output print() L395 Output print() L396 Output print() L397 Output print() L413 Output print() L431 Transform dict comprehension: {executor.submit(enrich_row, row): row for ...} L436 Decision for future in as_completed(future_to_row) L439 Decision if result['email'] L441 Transform .append() L446 Output print() L449 Output print() L453 Decision if updates_to_apply L454 Output print() L454 Transform len() L458 Decision try/except block L462 Decision for update in updates_to_apply L466 Transform .append() L478 Output print() L480 Output print() L481 Output print() L484 Decision for update in updates_to_apply L490 Output print() L491 Output print() L492 Output print() L504 Decision if result_url L505 Output print() L507 Output print()