import db


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