import db


def delete_flow_node(slug, node_id):
    conn = db.connect(slug)
    conn.execute("DELETE FROM _flow_edges WHERE from_node_id = ? OR to_node_id = ?", (node_id, node_id))
    conn.execute("DELETE FROM _flow_nodes WHERE id = ?", (node_id,))
    conn.commit()
    conn.close()