feat: forward dask logging

Author: jgaucher-cs

services/staging/rs_server_staging/processors.py

@@ -747,6 +747,9 @@ def dask_cluster_connect(self) -> Client:
         # create the client as well
         client = Client(self.cluster)
 
+        # Forward logging from dask workers to the caller
+        client.forward_logging()
+
         def set_dask_env(host_env: dict):
             """Pass environment variables to the dask workers."""
             for name in ["S3_ACCESSKEY", "S3_SECRETKEY", "S3_ENDPOINT", "S3_REGION"]: