Untitled
unknown
python
a year ago
1.6 kB
3
Indexable
--------------------------------------------------------------------------- TypeError Traceback (most recent call last) /local/dsako/repositories/bam_scraping/bin/reporting/test_analytics/broken_scrapes_no_cc.ipynb Cell 11 in () 3 open_incidents = pd_session.get_incidents(service=HP) 4 incidents_df = extract_dag_info(incidents_list=open_incidents) ----> 5 resolve_df = identify_resolvable_dags(incidents_df) 6 broken_df = incidents_df[~incidents_df["dag_id"].isin(resolve_df["dag_id"])] 8 record = { 9 "as_of": datetime.now(pytz.timezone("UTC")).strftime("%Y-%m-%d %H:%M:%S"), 10 "broken_scrapes": len(broken_df), 11 } File /local/dsako/repositories/bam_scraping/bin/monitoring/on_call/utils.py:463, in identify_resolvable_dags(incidents_df) 459 with AirflowAPISession() as session: 460 scrape_airflow_dags = session.get_dags() 461 scrape_airflow_incident_dags = [ 462 dag_id --> 463 for dag_id in incidents_df["dag_id"].unique().tolist() 464 if dag_id in scrape_airflow_dags["dag_id"].unique().tolist() 465 ] 467 logger.info( 468 f"Fetching latest runs for {len(scrape_airflow_incident_dags)} DAGs from scrape-airflow" 469 ) 471 scrape_airflow_last_runs = ( 472 session.get_latest_dag_runs(dag_ids=scrape_airflow_incident_dags) ... (...) 480 ) 481 ) TypeError: tuple indices must be integers or slices, not str
Editor is loading...
Leave a Comment