diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml index 118b8e80d9..722fce1f0d 100644 --- a/.github/workflows/ci.yaml +++ b/.github/workflows/ci.yaml @@ -74,4 +74,4 @@ jobs: uses: actions/upload-artifact@v2 with: name: runinfo-${{ matrix.python-version }} - path: . + path: runinfo/ diff --git a/parsl/executors/radical/executor.py b/parsl/executors/radical/executor.py index 5d5fc0f083..2a8aae5c75 100644 --- a/parsl/executors/radical/executor.py +++ b/parsl/executors/radical/executor.py @@ -181,21 +181,24 @@ def start(self): logger.info("starting RadicalPilotExecutor") logger.info('Parsl: {0}'.format(parsl.__version__)) logger.info('RADICAL pilot: {0}'.format(rp.version)) - self.session = rp.Session(uid=ru.generate_id('rpex.session', + self.session = rp.Session(cfg={'base': self.run_dir}, + uid=ru.generate_id('rpex.session', mode=ru.ID_PRIVATE)) - - if self.resource is None: - logger.error("specify remote or local resource") - - else: - pd_init = {'gpus': self.gpus, - 'cores': self.cores, - 'exit_on_error': True, - 'queue': self.partition, - 'project': self.project, - 'runtime': self.walltime, - 'resource': self.resource, - 'access_schema': self.access_schema} + logger.info(f"RPEX session is created: {0}".format(self.sesson.path)) + + pd_init = {'gpus': self.gpus, + 'cores': self.cores, + 'exit_on_error': True, + 'queue': self.partition, + 'project': self.project, + 'runtime': self.walltime, + 'resource': self.resource, + 'access_schema': self.access_schema} + + # move the agent sandbox in the workdir mainly for tests purposes + if not self.resource or 'local' in self.resource: + pd_init['sandbox'] = self.run_dir + logger.info("RPEX will be running in the local mode") pd = rp.PilotDescription(pd_init)