@@ -117,6 +117,7 @@ <h1>Source code for lomas_server.routes.utils</h1><div class="highlight"><pre>
117117< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> lomas_core.error_handler</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> UnauthorizedAccessException</ span >
118118< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> lomas_core.models.collections</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> UserId</ span >
119119< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> lomas_core.models.constants</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> TimeAttackMethod</ span >
120+ < span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> lomas_core.models.exceptions</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="n "> LomasServerExceptionTypeAdapter</ span >
120121< span class ="kn "> from</ span > < span class ="w "> </ span > < span class ="nn "> lomas_core.models.requests</ span > < span class ="w "> </ span > < span class ="kn "> import</ span > < span class ="p "> (</ span >
121122 < span class ="n "> DummyQueryModel</ span > < span class ="p "> ,</ span >
122123 < span class ="n "> LomasRequestModel</ span > < span class ="p "> ,</ span >
@@ -143,16 +144,17 @@ <h1>Source code for lomas_server.routes.utils</h1><div class="highlight"><pre>
143144 < span class ="k "> else</ span > < span class ="p "> :</ span >
144145 < span class ="k "> await</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> ack</ span > < span class ="p "> ()</ span >
145146
147+ < span class ="n "> message_body</ span > < span class ="o "> =</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> body</ span > < span class ="o "> .</ span > < span class ="n "> decode</ span > < span class ="p "> ()</ span >
146148 < span class ="k "> match</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> headers</ span > < span class ="p "> :</ span >
147149 < span class ="k "> case</ span > < span class ="p "> {</ span > < span class ="s2 "> "type"</ span > < span class ="p "> :</ span > < span class ="s2 "> "exception"</ span > < span class ="p "> ,</ span > < span class ="s2 "> "status_code"</ span > < span class ="p "> :</ span > < span class ="n "> status_code</ span > < span class ="p "> }:</ span >
148- < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> error</ span > < span class ="o "> =</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> body</ span > < span class ="o "> .</ span > < span class ="n "> decode</ span > < span class ="p "> ()</ span >
150+ < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> error</ span > < span class ="o "> =</ span > < span class ="p "> (</ span >
151+ < span class ="n "> LomasServerExceptionTypeAdapter</ span > < span class ="o "> .</ span > < span class ="n "> validate_json</ span > < span class ="p "> (</ span > < span class ="n "> message_body</ span > < span class ="p "> )</ span >
152+ < span class ="p "> )</ span >
149153 < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> status</ span > < span class ="o "> =</ span > < span class ="s2 "> "failed"</ span >
150154 < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> result</ span > < span class ="o "> =</ span > < span class ="kc "> None</ span >
151155 < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> status_code</ span > < span class ="o "> =</ span > < span class ="n "> status_code</ span >
152156 < span class ="k "> case</ span > < span class ="w "> </ span > < span class ="k "> _</ span > < span class ="p "> :</ span >
153- < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> result</ span > < span class ="o "> =</ span > < span class ="bp "> cls</ span > < span class ="o "> .</ span > < span class ="n "> model_validate_json</ span > < span class ="p "> (</ span >
154- < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> body</ span > < span class ="o "> .</ span > < span class ="n "> decode</ span > < span class ="p "> ()</ span >
155- < span class ="p "> )</ span >
157+ < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> result</ span > < span class ="o "> =</ span > < span class ="bp "> cls</ span > < span class ="o "> .</ span > < span class ="n "> model_validate_json</ span > < span class ="p "> (</ span > < span class ="n "> message_body</ span > < span class ="p "> )</ span >
156158 < span class ="n "> jobs</ span > < span class ="p "> [</ span > < span class ="n "> message</ span > < span class ="o "> .</ span > < span class ="n "> correlation_id</ span > < span class ="p "> ]</ span > < span class ="o "> .</ span > < span class ="n "> status</ span > < span class ="o "> =</ span > < span class ="s2 "> "complete"</ span > </ div >
157159
158160
0 commit comments