@@ -142,6 +142,7 @@ def __init__(self, pipeline_id: str, msg: str | None = None):
142142
143143class TaskSchedulingError (SchedulerError ):
144144 """A task cannot be scheduled"""
145+
145146 code : str = "task scheduler error"
146147
147148 def __init__ (self , project_id : ProjectID , node_id : NodeID , msg : str | None = None ):
@@ -224,12 +225,10 @@ def get_errors(self) -> list[ErrorDict]:
224225
225226
226227class ComputationalSchedulerChangedError (OsparcErrorMixin , SchedulerError ):
227- code = "computational_backend.scheduler_changed" # type: ignore
228228 msg_template = "The dask scheduler ID changed from '{original_scheduler_id}' to '{current_scheduler_id}'"
229229
230230
231231class ComputationalBackendNotConnectedError (OsparcErrorMixin , SchedulerError ):
232- code = "computational_backend.not_connected" # type: ignore
233232 msg_template = "The dask computational backend is not connected"
234233
235234
@@ -238,24 +237,20 @@ class ComputationalBackendNoS3AccessError(OsparcErrorMixin, SchedulerError):
238237
239238
240239class ComputationalBackendTaskNotFoundError (OsparcErrorMixin , SchedulerError ):
241- code = "computational_backend.task_not_found" # type: ignore
242240 msg_template = (
243241 "The dask computational backend does not know about the task '{job_id}'"
244242 )
245243
246244
247245class ComputationalBackendTaskResultsNotReadyError (OsparcErrorMixin , SchedulerError ):
248- code = "computational_backend.task_result_not_ready" # type: ignore
249246 msg_template = "The task result is not ready yet for job '{job_id}'"
250247
251248
252249class ClustersKeeperNotAvailableError (OsparcErrorMixin , SchedulerError ):
253- code = "computational_backend.clusters_keeper_not_available" # type: ignore
254250 msg_template = "clusters-keeper service is not available!"
255251
256252
257253class ComputationalBackendOnDemandNotReadyError (OsparcErrorMixin , SchedulerError ):
258- code = "computational_backend.on_demand_cluster.not_ready" # type: ignore
259254 msg_template = (
260255 "The on demand computational cluster is not ready 'est. remaining time: {eta}'"
261256 )
@@ -265,7 +260,6 @@ class ComputationalBackendOnDemandNotReadyError(OsparcErrorMixin, SchedulerError
265260# SCHEDULER/CLUSTER ERRORS
266261#
267262class ClusterNotFoundError (OsparcErrorMixin , SchedulerError ):
268- code = "cluster.not_found" # type: ignore
269263 msg_template = "The cluster '{cluster_id}' not found"
270264
271265
@@ -283,24 +277,20 @@ class ClusterInvalidOperationError(OsparcErrorMixin, SchedulerError):
283277
284278
285279class DaskClientRequestError (OsparcErrorMixin , SchedulerError ):
286- code = "dask_client.request.error" # type: ignore
287280 msg_template = (
288281 "The dask client to cluster on '{endpoint}' did an invalid request '{error}'"
289282 )
290283
291284
292285class DaskClusterError (OsparcErrorMixin , SchedulerError ):
293- code = "cluster.error" # type: ignore
294286 msg_template = "The dask cluster on '{endpoint}' encountered an error: '{error}'"
295287
296288
297289class DaskGatewayServerError (OsparcErrorMixin , SchedulerError ):
298- code = "gateway.error" # type: ignore
299290 msg_template = "The dask gateway on '{endpoint}' encountered an error: '{error}'"
300291
301292
302293class DaskClientAcquisisitonError (OsparcErrorMixin , SchedulerError ):
303- code = "dask_client.acquisition.error" # type: ignore
304294 msg_template = (
305295 "The dask client to cluster '{cluster}' encountered an error '{error}'"
306296 )
0 commit comments