set dask scheduler from env variable (#55)

* set dask scheduler from env variable

* fix default value

Author: francesconazzaro

cads_worker/worker.py

@@ -1,4 +1,5 @@
 import datetime
+import dask.config
 import distutils.util
 import functools
 import logging
@@ -10,6 +11,7 @@
 import cacholote
 import cads_adaptors
 import cads_broker.database
+import dask
 import distributed.worker
 import structlog
 from distributed import get_worker
@@ -204,6 +206,7 @@ def submit_workflow(
 
     logger.info("Processing job", job_id=job_id)
     collection_id = config.get("collection_id")
+    dask.config.set(scheduler=os.getenv("WORKER_SCHEDULER_TYPE", "processes"))
     cacholote.config.set(
         logger=LOGGER,
         cache_files_urlpath=cache_files_urlpath,