Skip to content

Commit e816703

Browse files
committed
simplify
1 parent b38cca6 commit e816703

File tree

1 file changed

+2
-5
lines changed
  • services/director-v2/src/simcore_service_director_v2/utils

1 file changed

+2
-5
lines changed

services/director-v2/src/simcore_service_director_v2/utils/dask.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -481,7 +481,7 @@ def check_scheduler_is_still_the_same(
481481
)
482482

483483

484-
def check_communication_with_scheduler_is_open(client: distributed.Client):
484+
def check_communication_with_scheduler_is_open(client: distributed.Client) -> None:
485485
if (
486486
client.scheduler_comm
487487
and client.scheduler_comm.comm is not None
@@ -490,12 +490,9 @@ def check_communication_with_scheduler_is_open(client: distributed.Client):
490490
raise ComputationalBackendNotConnectedError
491491

492492

493-
def check_scheduler_status(client: distributed.Client):
493+
def check_scheduler_status(client: distributed.Client) -> None:
494494
client_status = client.status
495495
if client_status not in "running":
496-
_logger.error(
497-
"The computational backend is not connected!",
498-
)
499496
raise ComputationalBackendNotConnectedError
500497

501498

0 commit comments

Comments
 (0)