Changed the way we get the sge.project variable

bob/pipelines/distributed/sge.py

@@ -37,12 +37,13 @@ class SGEIdiapJob(Job):
         self,
         *args,
         queue=None,
-        project=rc['sge.project'],
+        project=rc.get("sge.project"),
         resource_spec=None,
         job_extra=None,
         config_name="sge",
         **kwargs,
     ):
+
         if queue is None:
             queue = dask.config.get("jobqueue.%s.queue" % config_name)
         if project is None:
@@ -206,7 +207,7 @@ class SGEMultipleQueuesCluster(JobQueueCluster):
         env_extra=None,
         sge_job_spec=QUEUE_DEFAULT,
         min_jobs=10,
-        project=rc['sge.project'],
+        project=rc.get('sge.project'),
         **kwargs,
 
     ):
@@ -217,6 +218,7 @@ class SGEMultipleQueuesCluster(JobQueueCluster):
 
         self.protocol = protocol
         self.log_directory = log_directory
+        self.project = project
 
         silence_logs = "error"
         secutity = None
@@ -224,6 +226,7 @@ class SGEMultipleQueuesCluster(JobQueueCluster):
         host = None
         security = None
 
+
         if env_extra is None:
             env_extra = []
         elif not isinstance(env_extra, list):
@@ -292,7 +295,7 @@ class SGEMultipleQueuesCluster(JobQueueCluster):
 
         return {
             "queue": queue,
-            "project": project,
+            "project": self.project,
             "memory": _get_key_from_spec(job_spec, "memory"),
             "cores": 1,
             "processes": 1,