import db


def delete_flow_edge(slug: str, edge_id: int) -> None:
    conn = db.connect(slug)
    conn.execute("DELETE FROM _flow_edges WHERE id = ?", (edge_id,))
    conn.commit()
    conn.close()