Merge pull request #131 from openedx/cag/coalesce-actor-id

fix: invert join side to user user_profiles as base table

models/users/user_pii.sql

@@ -4,7 +4,7 @@
         schema=env_var("ASPECTS_EVENT_SINK_DATABASE", "event_sink"),
         fields=[
             ("user_id", "Int32"),
-            ("external_user_id", "UUID"),
+            ("external_user_id", "String"),
             ("username", "String"),
             ("name", "String"),
             ("email", "String"),
@@ -25,9 +25,19 @@ with
         from {{ source("event_sink", "user_profile") }}
         group by user_id
     )
-select ex.user_id as user_id, ex.external_user_id, ex.username, up.name, up.email
-from {{ source("event_sink", "external_id") }} ex
-left outer join most_recent_user_profile mrup on mrup.user_id = ex.user_id
+select
+    ex.user_id as user_id,
+    if(
+        empty(ex.external_user_id),
+        concat('mailto:', email),
+        ex.external_user_id::String
+    ) as external_user_id,
+    up.username as username,
+    up.name as name,
+    up.email as email
+from most_recent_user_profile mrup
+left outer join
+    {{ source("event_sink", "external_id") }} ex on mrup.user_id = ex.user_id
 left outer join
     {{ source("event_sink", "user_profile") }} up
     on up.user_id = mrup.user_id