modal_webhook.py

L33 API Call modal.App() L77 Decision while n >= 0 L244 Decision if creds.expired L254 Output logger.info() L272 Decision if creds.expired L282 Output logger.info() L282 Transform len() L283 Transform len() L300 Decision if creds.expired L311 Output logger.info() L320 Decision if not api_key L327 API Call requests.get() L329 Decision if response.status_code != 200 L330 Output logger.error() L335 Output logger.info() L335 Transform len() L339 Decision for item in items L340 Transform .append() L352 Transform len() L360 Decision if not api_key L375 API Call requests.post() L377 Decision if response.status_code not in [200, 201] L378 Output logger.error() L381 Output logger.info() L398 Decision try/except block L399 API Call requests.get() L405 Decision if data.get('Abstract') L406 Transform .append() L414 Decision for topic in data.get('RelatedTopics', [])[:5] L415 Decision if isinstance(topic, dict) and topic.get('Text') L416 Transform .append() L423 Decision if not results L425 Transform .append() L431 Output logger.info() L431 Transform len() L435 Output logger.error() L436 Transform str() L443 Decision try/except block L447 API Call requests.get() L461 Transform .strip() L464 Decision if len(text) > 15000 L464 Transform len() L467 Output logger.info() L467 Transform len() L468 Transform len() L471 Output logger.error() L472 Transform str() L480 Decision if not API_KEY L491 API Call client.get() L493 Transform str() L494 Transform str() L495 Transform str() L504 API Call client.get() L510 API Call client.get() L514 API Call client.get() L515 API Call client.get() L516 API Call client.get() L528 Decision try/except block L529 API Call requests.post() L536 Output logger.info() L541 API Call client.get() L546 Output logger.error() L547 Transform str() L572 Decision if not webhook_url L576 Decision if blocks L579 Decision try/except block L580 Transform .encode() L580 Transform .dumps() L584 Output logger.error() L589 Transform .dumps() L603 Transform len() L609 Transform .dumps() L616 Transform len() L622 Transform len() L664 Decision try/except block L670 Decision if hasattr(module, 'run') L678 Output logger.error() L679 Transform str() L689 Decision if not config_path.exists() L691 Transform .loads() L691 File I/O .read_text() L697 Decision if not directive_path.exists() L699 File I/O .read_text() L713 API Call anthropic.Anthropic() L722 Transform .dumps() L732 Transform list comprehension: [ALL_TOOLS[t] for ...] L741 Output logger.info() L756 Decision while response.stop_reason == 'tool_use' and turn_count < max_turns L760 Decision for block in response.content L761 Decision if block.type == 'thinking' L762 Transform .append() L767 Decision if not tool_use L771 Decision if tool_use.name not in allowed_tools L772 Transform .dumps() L776 Transform .append() L780 Decision try/except block L782 Decision if impl L784 Decision if tool_use.name in TOOLS_NEEDING_TOKEN L788 Transform .dumps() L790 Transform .dumps() L793 Output logger.error() L794 Transform .dumps() L794 Transform str() L801 Transform .append() L802 Transform .append() L810 Decision for block in response.content L811 Decision if hasattr(block, 'text') L813 Decision if block.type == 'thinking' L814 Transform .append() L832 API Call modal.fastapi_endpoint() L853 Decision if slug not in webhooks L854 Transform list() L857 Transform .loads() L866 Decision if script_name L867 Output logger.info() L870 Decision try/except block L875 Transform .dumps() L886 Output logger.error() L887 Transform str() L888 Transform str() L893 Decision if directive_name L896 Decision try/except block L899 Transform str() L901 Decision try/except block L922 Output logger.error() L923 Transform str() L924 Transform str() L930 API Call modal.fastapi_endpoint() L937 Transform dict comprehension: {slug: {'directive': cfg.get('directive'), 'script': cfg.get('script'), 'description': cfg.get('description', ''), 'tools': cfg.get('tools', [])} for ...} L958 Decision for f in directives_dir.glob('*.md') L959 File I/O .read_text() L961 Transform .title() L961 Transform .replace() L964 Decision for line in content.split('\n') L964 Transform .split() L965 Decision if line.startswith('## Goal') or line.startswith('## Description') L968 Transform .strip() L968 Transform len() L969 Transform .strip() L969 Transform .split() L972 Transform .append() L986 Decision for f in scripts_dir.glob('*.py') L987 Decision if f.stem.startswith('_') L990 File I/O .read_text() L992 Decision if '"""' in content L995 Decision if end > start L996 Transform .split() L996 Transform .strip() L998 Transform .append() L1055 Decision if tool_name == 'list_directives' L1058 Decision if tool_name == 'read_directive' L1060 Decision try/except block L1066 Decision if tool_name == 'list_scripts' L1069 Decision if tool_name == 'run_script' L1075 Decision if not Path(script_path).exists() L1078 Decision try/except block L1082 Transform len() L1083 Transform len() L1089 Transform str() L1092 Decision if tool_name in TOOL_IMPLEMENTATIONS L1094 Decision if tool_name in TOOLS_NEEDING_TOKEN L1109 API Call modal.fastapi_endpoint() L1119 Decision if not query L1130 Decision if not api_key L1134 Decision try/except block L1135 Transform .loads() L1151 Transform list() L1154 API Call anthropic.Anthropic() L1157 Decision try/except block L1171 Decision while response.stop_reason == 'tool_use' and turns < max_turns L1175 Decision for block in response.content L1176 Decision if block.type == 'tool_use' L1179 Decision try/except block L1181 Transform .dumps() L1181 Transform str() L1184 Transform .dumps() L1184 Transform str() L1185 Transform str() L1187 Transform .append() L1188 Transform .append() L1194 Transform .append() L1195 Transform .append() L1207 Decision for block in response.content L1208 Decision if hasattr(block, 'text') L1222 Transform str() L1223 Transform str() L1233 Decision if not config_path.exists() L1235 Transform .loads() L1235 File I/O .read_text() L1252 Decision if creds.expired L1257 Transform .append() L1284 Decision try/except block L1286 Transform .loads() L1287 Decision if not token_data L1299 Decision if creds.expired L1323 Output logger.info() L1329 Output logger.error() L1330 Transform str() L1331 Transform str() L1350 Decision if not scraper_config L1351 Output logger.error() L1364 Decision if not api_token L1378 Decision try/except block L1382 Decision for item in client.dataset(run['defaultDatasetId']).iterate_items() L1383 Transform .append() L1385 Output logger.info() L1385 Transform len() L1387 Decision if not results L1394 Decision for r in results L1395 Transform .append() L1408 Transform .loads() L1411 Transform len() L1415 Transform len() L1421 Output logger.error() L1422 Transform str() L1423 Transform str() L1447 Decision try/except block L1452 Decision if not api_token L1461 Transform .lower() L1465 API Call apify_client.actor() L1468 Decision for item in apify_client.dataset(run['defaultDatasetId']).iterate_items() L1468 API Call apify_client.dataset() L1469 Transform .append() L1471 Output logger.info() L1471 Transform len() L1473 Decision if not results L1478 Transform len() L1482 Transform .loads() L1491 Decision if creds.expired L1494 API Call gspread.authorize() L1503 Decision if 'first_name' in df.columns L1508 Decision if 'company_name' in df.columns L1513 Decision if 'city' in df.columns L1525 Transform len() L1526 Transform len() L1527 Decision if required_rows > worksheet.row_count or required_cols > worksheet.col_count L1528 Transform max() L1528 Transform max() L1537 Decision if not amf_api_key L1551 Decision for (row_idx, row) in enumerate(all_data[1:], start=2) L1551 Transform enumerate() L1552 Decision if email_col >= 0 and row[email_col] L1561 Decision if website L1562 Transform .split() L1562 Transform .replace() L1562 Transform .replace() L1562 Transform .replace() L1565 Transform .split() L1567 Transform len() L1570 Decision try/except block L1575 Decision if contact_name L1577 Decision if first_name L1579 Decision if last_name L1581 Decision if domain L1583 Decision if company_name L1586 Decision if (first_name or contact_name) and (domain or company_name) L1588 Decision if resp.status_code == 200 L1591 Decision if email L1597 Output logger.warning() L1605 Decision if not anthropic_key L1608 API Call anthropic.Anthropic() L1625 Transform len() L1627 Decision for (batch_num, batch_start) in enumerate(range(0, len(data_rows), BATCH_SIZE), 1) L1627 Transform enumerate() L1627 Transform len() L1628 Transform min() L1628 Transform len() L1633 Decision for row in batch_rows L1634 Transform len() L1635 Transform len() L1636 Transform len() L1637 Transform .append() L1643 Decision if not any((r['first_name'] or r['company_name'] or r['city'] for r in records)) L1647 Transform .dumps() L1647 Transform list comprehension: [{'id': i + 1, 'first_name': r['first_name'], 'company_name': r['company_name'], 'city': r['city']} for ...] L1649 Transform enumerate() L1663 Decision try/except block L1669 Transform .strip() L1672 Decision if response_text.startswith('```') L1673 Transform .split() L1674 Transform .join() L1677 Transform .loads() L1681 Decision for (i, result) in enumerate(results_json) L1681 Transform enumerate() L1684 Decision if casual_first_col >= 0 L1687 Transform .append() L1689 Decision if casual_company_col >= 0 L1692 Transform .append() L1694 Decision if casual_city_col >= 0 L1697 Transform .append() L1699 Decision if updates L1702 Output logger.info() L1705 Output logger.warning() L1708 Transform len() L1712 Transform len() L1717 Output logger.error() L1718 Transform str() L1719 Transform str() L1723 API Call modal.fastapi_endpoint() L1744 Decision if not query L1751 Decision try/except block L1753 Transform .loads() L1762 Decision if creds.expired L1765 API Call gspread.authorize() L1793 Output logger.error() L1794 Transform str() L1797 Transform str() L1802 API Call modal.fastapi_endpoint() L1816 Decision if not request_body L1854 Decision try/except block L1858 Decision if not API_KEY L1871 API Call client.get() L1873 Transform str() L1874 Transform str() L1875 Transform str() L1884 API Call client.get() L1890 API Call client.get() L1894 API Call client.get() L1895 API Call client.get() L1896 API Call client.get() L1908 API Call requests.post() L1915 API Call client.get() L1921 API Call client.get() L1926 Output logger.error() L1927 Transform str() L1930 Transform str() L1935 API Call modal.fastapi_endpoint() L1950 Decision if name not in transcript_map L1954 Transform list() L1957 Decision try/except block L1958 File I/O open() L1969 Transform str() L1974 API Call modal.fastapi_endpoint() L1999 Decision if transcript not in transcript_map L2003 Transform list() L2008 Decision try/except block L2010 File I/O open() L2013 Transform len() L2017 Decision if not anthropic_key L2020 API Call anthropic.Anthropic() L2074 Transform .strip() L2077 Decision if response_text.startswith('```') L2078 Transform .split() L2079 Transform .join() L2081 Transform .loads() L2087 Decision if not API_KEY L2102 Transform str() L2103 Transform str() L2104 Transform str() L2137 API Call requests.post() L2157 Output logger.error() L2158 Transform str() L2161 Transform str() L2166 Output logger.error() L2167 Transform str() L2170 Transform str() L2186 Decision if not apify_token L2193 Decision for keyword in keywords L2194 Decision try/except block L2208 Decision for item in client.dataset(run['defaultDatasetId']).iterate_items() L2210 Decision if not video_id L2212 Decision if 'v=' in url L2213 Transform .split() L2213 Transform .split() L2228 Decision if video_data['title'] and video_data['video_id'] L2229 Transform .append() L2235 Transform str() L2236 Output logger.error() L2252 Decision if not video_id L2255 Decision try/except block L2258 API Call apify_client.actor() L2260 Transform list() L2260 API Call apify_client.dataset() L2262 Decision if dataset_items and len(dataset_items) > 0 L2262 Transform len() L2265 Decision if captions and isinstance(captions, list) L2266 Transform .join() L2270 Output logger.warning() L2270 Transform str() L2288 Decision try/except block L2321 Decision try/except block L2323 Transform len() L2327 Transform dict comprehension: {v['video_id']: v for ...} L2328 Transform list() L2330 Transform len() L2332 Decision if not videos L2343 Transform list comprehension: [v for ...] L2350 Decision for (i, video) in enumerate(top_outliers) L2350 Transform enumerate() L2354 Transform len() L2356 Decision if not top_outliers L2358 Transform len() L2366 Decision if apify_token and anthropic_key L2368 API Call anthropic.Anthropic() L2377 Transform list comprehension: [executor.submit(process_outlier, v) for ...] L2378 Transform list comprehension: [future.result() for ...] L2381 Decision for video in top_outliers L2387 Transform len() L2389 Transform .loads() L2398 Decision if creds.expired L2401 API Call gspread.authorize() L2409 Decision for v in top_outliers L2410 Transform .append() L2424 Transform len() L2426 Transform len() L2426 Transform len() L2429 Output logger.error() L2430 Transform str() L2431 Transform str() L2435 API Call modal.fastapi_endpoint() L2468 Transform list comprehension: [k.strip() for ...] L2468 Transform .strip() L2468 Transform .split() L2468 Transform .strip() L2470 Decision try/except block L2471 Transform .loads() L2480 Decision if creds.expired L2483 API Call gspread.authorize() L2489 Transform .join() L2489 Transform len() L2510 Output logger.error() L2511 Transform str() L2512 Transform str() L2517 Output print() L2518 Output print() L2519 Output print() L2520 Output print() L2521 Output print() L2522 Output print() L2523 Output print() L2524 Output print() L2525 Output print() L2526 Output print() L2527 Output print() L2528 Output print() L2529 Output print() L2530 Output print() L2531 Output print() L2532 Output print() L2533 Output print() L2534 Output print() L2535 Output print() L2536 Output print() L2537 Output print() L2538 Output print()