fixed test

Author: sanderegg

services/director-v2/tests/unit/test_modules_dask_client.py

@@ -20,7 +20,6 @@
 from dask_task_models_library.container_tasks.docker import DockerBasicAuth
 from dask_task_models_library.container_tasks.errors import TaskCancelledError
 from dask_task_models_library.container_tasks.events import (
-    TaskLogEvent,
     TaskProgressEvent,
 )
 from dask_task_models_library.container_tasks.io import (
@@ -1104,9 +1103,7 @@ def fake_remote_fct(
         s3_settings: S3Settings | None,
     ) -> TaskOutputData:
         progress_pub = distributed.Pub(TaskProgressEvent.topic_name())
-        logs_pub = distributed.Pub(TaskLogEvent.topic_name())
         progress_pub.put("my name is progress")
-        logs_pub.put("my name is logs")
         # tell the client we are done
         published_event = Event(name=_DASK_START_EVENT)
         published_event.set()