def model(dbt, session): # Load the source data orders = dbt.ref("orders").to_pandas() # Perform transformations using pandas orders_summary = orders.groupby('customer_id').agg( total_orders=('order_id', 'count'), total_revenue=('order_amount', 'sum') ).reset_index() return orders_summary
интересный здесь код на входе он принимает некий объект dbt. dbt обладает свойством реф и типа мы как бы считываем модель ордерс и переводим это в пандас ну и дальше красиво у нас в 4 строки решается задача которой в скл решается за большее количество строк вот красиво