File tree Expand file tree Collapse file tree 1 file changed +1
-24
lines changed
packages/pytest-simcore/src/pytest_simcore/helpers Expand file tree Collapse file tree 1 file changed +1
-24
lines changed Original file line number Diff line number Diff line change @@ -238,18 +238,6 @@ class NodeProgressEvent:
238238 total_progress : float
239239
240240
241- class ServiceStatus (str , Enum ):
242- IDLE = "idle"
243- RUNNING = "running"
244- FAILED = "failed"
245-
246-
247- @dataclass (frozen = True , slots = True , kw_only = True )
248- class NodeServicestatusEvent :
249- node_id : str
250- status : ServiceStatus
251-
252-
253241def retrieve_node_progress_from_decoded_message (
254242 event : SocketIOEvent ,
255243) -> NodeProgressEvent :
@@ -264,18 +252,6 @@ def retrieve_node_progress_from_decoded_message(
264252 )
265253
266254
267- def retrieve_node_service_status_from_decoded_message (
268- event : SocketIOEvent ,
269- ) -> NodeServicestatusEvent :
270- assert event .name == _OSparcMessages .SERVICE_STATUS .value
271- assert "progress_type" in event .obj
272- assert "progress_report" in event .obj
273- return NodeServicestatusEvent (
274- node_id = event .obj ["service_uuid" ],
275- status = ServiceStatus (event .obj ["service_state" ]),
276- )
277-
278-
279255@dataclass
280256class SocketIOProjectClosedWaiter :
281257 logger : logging .Logger
@@ -362,6 +338,7 @@ def __call__(self, message: str) -> bool:
362338 in _FAIL_FAST_DYNAMIC_SERVICE_STATES
363339 )
364340 ):
341+ # NOTE: this is a fail fast for dynamic services that fail to start
365342 self .logger .error (
366343 "node %s failed with state %s, failing fast" ,
367344 self .node_id ,
You can’t perform that action at this time.
0 commit comments