create_rep_data.sql

  config {
  type: "operations",
  hasOutput: true,
  schema: "production",
  disabled: false,
  name: "reputation_data",
  tags: ["reputation_data"],
  description: "reputation_data pipeline real-time updates from events."

}

create table if not exists ${self()}  (
  src string
)
PARTITION BY DATE(_PARTITIONTIME)
;
insert ${self()} (src)
-- insert production.reputation_data (src)
select
'{"user_id":1,"reputation_level":3.5,"updated_at":"1999-01-01 00:00:01 UTC"}'
;