@@ -90,6 +90,23 @@ def handle_dlq_messages(messages_path: list[Path], rabbitmq_credentials: Path):
9090
9191def handle_failed_posts (messages_path : list [Path ], murfey_db : Session ):
9292 """Deal with any messages that have been sent as failed client posts"""
93+ # These imports need to happen after transport object is configured
94+ import murfey .server .api .auth
95+ import murfey .server .api .bootstrap
96+ import murfey .server .api .clem
97+ import murfey .server .api .display
98+ import murfey .server .api .file_io_frontend
99+ import murfey .server .api .file_io_instrument
100+ import murfey .server .api .hub
101+ import murfey .server .api .instrument
102+ import murfey .server .api .mag_table
103+ import murfey .server .api .processing_parameters
104+ import murfey .server .api .prometheus
105+ import murfey .server .api .session_control
106+ import murfey .server .api .session_info
107+ import murfey .server .api .websocket
108+ import murfey .server .api .workflow
109+
93110 for json_file in messages_path :
94111 with open (json_file , "r" ) as json_data :
95112 message = json .load (json_data )
@@ -103,23 +120,6 @@ def handle_failed_posts(messages_path: list[Path], murfey_db: Session):
103120 continue
104121
105122 try :
106- # These imports need to happen after transport object is configured
107- import murfey .server .api .auth
108- import murfey .server .api .bootstrap
109- import murfey .server .api .clem
110- import murfey .server .api .display
111- import murfey .server .api .file_io_frontend
112- import murfey .server .api .file_io_instrument
113- import murfey .server .api .hub
114- import murfey .server .api .instrument
115- import murfey .server .api .mag_table
116- import murfey .server .api .processing_parameters
117- import murfey .server .api .prometheus
118- import murfey .server .api .session_control
119- import murfey .server .api .session_info
120- import murfey .server .api .websocket
121- import murfey .server .api .workflow
122-
123123 function_to_call = getattr (
124124 getattr (murfey .server .api , router_base ), function_name
125125 )
0 commit comments