Untitled

 avatar
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