HIGH_PROFILE label for RRT

gwcelery/tasks/orchestrator.py

@@ -22,6 +22,7 @@ from . import gracedb
 from . import inference
 from . import igwn_alert
 from . import p_astro
+from . import rrt_utils
 from . import skymaps
 from . import superevents
 
@@ -1081,10 +1082,14 @@ def earlywarning_preliminary_initial_update_alert(
     # For kafka alerts the analogous field is set in alerts.py.
     # (see comment before defining kafka_alert_canvas)
     voevent_significance = 0 if alert_type == 'less-significant' else 1
-
     if filecontents and not combined_skymap_filename:
         skymap, em_bright, p_astro = filecontents
 
+        # check high profile and apply label if true
+        high_profile_canvas = rrt_utils.check_high_profile.si(
+            skymap, em_bright, p_astro, superevent
+        )
+
         download_andor_expose_group = []
 
         voevent_canvas = _create_voevent.si(
@@ -1114,6 +1119,7 @@ def earlywarning_preliminary_initial_update_alert(
             gracedb.download.si(em_bright_filename, superevent_id),
             gracedb.download.si(p_astro_filename, superevent_id),
         ]
+        high_profile_canvas = identity.si()
 
         voevent_canvas = _create_voevent.s(
             superevent_id,
@@ -1179,6 +1185,7 @@ def earlywarning_preliminary_initial_update_alert(
         group(
             sent_label_canvas,
             circular_canvas,
+            high_profile_canvas
         )
     )