From 7287fbe68e50917702b5ed83a916181c5e26d6c4 Mon Sep 17 00:00:00 2001 From: Eugene Dobry Date: Mon, 17 Mar 2025 16:58:16 -0400 Subject: [PATCH] only first participant is sequencer --- src/el_cl_launcher.star | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/src/el_cl_launcher.star b/src/el_cl_launcher.star index dc23d38a..469bf198 100644 --- a/src/el_cl_launcher.star +++ b/src/el_cl_launcher.star @@ -154,6 +154,7 @@ def launch( all_cl_contexts = [] all_el_contexts = [] sequencer_enabled = True + sequencer_context = None rollup_boost_enabled = "rollup-boost" in additional_services external_builder = mev_params.builder_host != "" and mev_params.builder_port != "" @@ -249,7 +250,6 @@ def launch( index_str, l2_services_suffix ) - sequencer_context = all_el_contexts[0] if len(all_el_contexts) > 0 else None el_context = el_launch_method( plan, el_launcher, @@ -266,9 +266,9 @@ def launch( interop_params, ) - # We need to make sure that el_context and cl_context are first in the list, as down the line all_el_contexts[0] - # and all_cl_contexts[0] are used - all_el_contexts.insert(0, el_context) + all_el_contexts.append(el_context) + if sequencer_enabled: + sequencer_context = el_context for metrics_info in [x for x in el_context.el_metrics_info if x != None]: observability.register_node_metrics_job( @@ -361,9 +361,7 @@ def launch( da_server_context, ) - # We need to make sure that el_context and cl_context are first in the list, as down the line all_el_contexts[0] - # and all_cl_contexts[0] are used - all_cl_contexts.insert(0, cl_context) + all_cl_contexts.append(cl_context) for metrics_info in [x for x in cl_context.cl_nodes_metrics_info if x != None]: observability.register_node_metrics_job( @@ -411,5 +409,9 @@ def launch( ) all_cl_contexts.append(cl_builder_context) + # only the first participant is the sequencer + if sequencer_enabled: + sequencer_enabled = False + plan.print("Successfully added {0} EL/CL participants".format(num_participants)) return all_el_contexts, all_cl_contexts