moved task life cycle plugins to dask-task-library

Author: sanderegg

packages/dask-task-models-library/src/dask_task_models_library/plugins/__init__.py

@@ -3,11 +3,12 @@
 
 import click
 from dask.typing import Key
-from dask_task_models_library.models import TASK_LIFE_CYCLE_EVENT, TaskLifeCycleState
 from distributed import Scheduler, SchedulerPlugin
 from distributed.scheduler import TaskStateState
 from servicelib.logging_utils import log_context
 
+from ..models import TASK_LIFE_CYCLE_EVENT, TaskLifeCycleState
+
 _logger = logging.getLogger(__name__)
 
 

services/dask-sidecar/src/simcore_service_dask_sidecar/task_life_cycle_scheduler_plugin.py renamed to packages/dask-task-models-library/src/dask_task_models_library/plugins/task_life_cycle_scheduler_plugin.py

@@ -4,12 +4,13 @@
 
 import click
 from dask.typing import Key
-from dask_task_models_library.models import TASK_LIFE_CYCLE_EVENT, TaskLifeCycleState
 from distributed import WorkerPlugin
 from distributed.worker import Worker
 from distributed.worker_state_machine import TaskStateState
 from servicelib.logging_utils import log_context
 
+from ..models import TASK_LIFE_CYCLE_EVENT, TaskLifeCycleState
+
 _logger = logging.getLogger(__name__)