RWM Console cluster: risingwave.platform.svc.cluster.local

CREATE MATERIALIZED VIEW authz.team_to_tasks_mv AS
SELECT
  team_id,
  task_id,
  updated_at
FROM (
  SELECT
    team_id,
    task_id,
    updated_at,
    ROW_NUMBER() OVER (PARTITION BY team_id, task_id ORDER BY updated_at DESC) AS rn
  FROM (
    SELECT
      ttc.team_id,
      t.task_id,
      t.updated_at
    FROM crm_service.tasks_dm AS t
    JOIN authz.team_to_clients_mv AS ttc
      ON ttc.client_id = t.resource_client_id
    WHERE
      t.disabled_at IS NULL
    UNION ALL
    SELECT
      tta.team_id,
      t.task_id,
      t.updated_at
    FROM crm_service.tasks_dm AS t
    JOIN authz.team_to_accounts_mv AS tta
      ON tta.account_id = t.resource_account_id
    WHERE
      t.disabled_at IS NULL
    UNION ALL
    SELECT
      ttp.team_id,
      t.task_id,
      t.updated_at
    FROM crm_service.tasks_dm AS t
    JOIN authz.team_to_portfolios_mv AS ttp
      ON ttp.portfolio_id = t.resource_portfolio_id
    WHERE
      t.disabled_at IS NULL
    UNION ALL
    SELECT
      ttp.team_id,
      t.task_id,
      t.updated_at
    FROM crm_service.tasks_dm AS t
    JOIN authz.team_to_parties_mv AS ttp
      ON ttp.party_id = t.resource_party_id
    WHERE
      t.disabled_at IS NULL
  )
)
WHERE
  rn = 1