import db


def get_flow_node(slug, node_id):
    conn = db.connect(slug)
    row = conn.execute("SELECT * FROM _flow_nodes WHERE id = ?", (node_id,)).fetchone()
    conn.close()
    return dict(row) if row else None