Skip to content
Snippets Groups Projects
Commit f8ee8af1 authored by Stefano Alberto Russo's avatar Stefano Alberto Russo
Browse files

Fixed require_user_auth_conf and require_user_auth_keys names.

parent 79fed45c
No related branches found
No related tags found
No related merge requests found
...@@ -164,7 +164,7 @@ class RemoteComputingManager(ComputingManager): ...@@ -164,7 +164,7 @@ class RemoteComputingManager(ComputingManager):
user = task.computing.get_conf_param('user') user = task.computing.get_conf_param('user')
# Get user keys # Get user keys
if task.computing.require_user_auth_keys: if task.computing.require_user_keys:
user_keys = Keys.objects.get(user=task.user, default=True) user_keys = Keys.objects.get(user=task.user, default=True)
else: else:
raise NotImplementedError('Remote tasks not requiring keys are not yet supported') raise NotImplementedError('Remote tasks not requiring keys are not yet supported')
...@@ -237,7 +237,7 @@ class RemoteComputingManager(ComputingManager): ...@@ -237,7 +237,7 @@ class RemoteComputingManager(ComputingManager):
def _stop_task(self, task, **kwargs): def _stop_task(self, task, **kwargs):
# Get user keys # Get user keys
if task.computing.require_user_auth_keys: if task.computing.require_user_keys:
user_keys = Keys.objects.get(user=task.user, default=True) user_keys = Keys.objects.get(user=task.user, default=True)
else: else:
raise NotImplementedError('Remote tasks not requiring keys are not yet supported') raise NotImplementedError('Remote tasks not requiring keys are not yet supported')
...@@ -264,7 +264,7 @@ class RemoteComputingManager(ComputingManager): ...@@ -264,7 +264,7 @@ class RemoteComputingManager(ComputingManager):
host = task.computing.get_conf_param('host') host = task.computing.get_conf_param('host')
# Get id_rsa # Get id_rsa
if task.computing.require_user_auth_keys: if task.computing.require_user_keys:
user_keys = Keys.objects.get(user=task.user, default=True) user_keys = Keys.objects.get(user=task.user, default=True)
id_rsa_file = user_keys.private_key_file id_rsa_file = user_keys.private_key_file
else: else:
...@@ -291,7 +291,7 @@ class SlurmComputingManager(ComputingManager): ...@@ -291,7 +291,7 @@ class SlurmComputingManager(ComputingManager):
user = task.computing.get_conf_param('user') user = task.computing.get_conf_param('user')
# Get user keys # Get user keys
if task.computing.require_user_auth_keys: if task.computing.require_user_keys:
user_keys = Keys.objects.get(user=task.user, default=True) user_keys = Keys.objects.get(user=task.user, default=True)
else: else:
raise NotImplementedError('Remote tasks not requiring keys are not yet supported') raise NotImplementedError('Remote tasks not requiring keys are not yet supported')
...@@ -390,7 +390,7 @@ class SlurmComputingManager(ComputingManager): ...@@ -390,7 +390,7 @@ class SlurmComputingManager(ComputingManager):
def _stop_task(self, task, **kwargs): def _stop_task(self, task, **kwargs):
# Get user keys # Get user keys
if task.computing.require_user_auth_keys: if task.computing.require_user_keys:
user_keys = Keys.objects.get(user=task.user, default=True) user_keys = Keys.objects.get(user=task.user, default=True)
else: else:
raise NotImplementedError('Remote tasks not requiring keys are not yet supported') raise NotImplementedError('Remote tasks not requiring keys are not yet supported')
...@@ -414,7 +414,7 @@ class SlurmComputingManager(ComputingManager): ...@@ -414,7 +414,7 @@ class SlurmComputingManager(ComputingManager):
def _get_task_log(self, task, **kwargs): def _get_task_log(self, task, **kwargs):
# Get user keys # Get user keys
if task.computing.require_user_auth_keys: if task.computing.require_user_keys:
user_keys = Keys.objects.get(user=task.user, default=True) user_keys = Keys.objects.get(user=task.user, default=True)
else: else:
raise NotImplementedError('Remote tasks not requiring keys are not yet supported') raise NotImplementedError('Remote tasks not requiring keys are not yet supported')
......
...@@ -113,8 +113,8 @@ class Command(BaseCommand): ...@@ -113,8 +113,8 @@ class Command(BaseCommand):
name = 'Local', name = 'Local',
type = 'local', type = 'local',
require_sys_conf = False, require_sys_conf = False,
require_user_auth_conf = False, require_user_conf = False,
require_user_auth_keys = False) require_user_keys = False)
#============================== #==============================
...@@ -124,8 +124,8 @@ class Command(BaseCommand): ...@@ -124,8 +124,8 @@ class Command(BaseCommand):
name = 'Demo remote', name = 'Demo remote',
type = 'remote', type = 'remote',
require_sys_conf = True, require_sys_conf = True,
require_user_auth_conf = True, require_user_conf = True,
require_user_auth_keys = True) require_user_keys = True)
ComputingSysConf.objects.create(computing = demo_remote_auth_computing, ComputingSysConf.objects.create(computing = demo_remote_auth_computing,
data = {'host': 'slurmclusterworker-one'}) data = {'host': 'slurmclusterworker-one'})
...@@ -142,8 +142,8 @@ class Command(BaseCommand): ...@@ -142,8 +142,8 @@ class Command(BaseCommand):
name = 'Demo Slurm', name = 'Demo Slurm',
type = 'slurm', type = 'slurm',
require_sys_conf = True, require_sys_conf = True,
require_user_auth_conf = True, require_user_conf = True,
require_user_auth_keys = True) require_user_keys = True)
# Create demo slurm sys computing conf # Create demo slurm sys computing conf
ComputingSysConf.objects.create(computing = demo_slurm_computing, ComputingSysConf.objects.create(computing = demo_slurm_computing,
......
...@@ -112,8 +112,8 @@ class Computing(models.Model): ...@@ -112,8 +112,8 @@ class Computing(models.Model):
type = models.CharField('Computing Type', max_length=255, blank=False, null=False) type = models.CharField('Computing Type', max_length=255, blank=False, null=False)
require_sys_conf = models.BooleanField(default=False) require_sys_conf = models.BooleanField(default=False)
require_user_auth_conf = models.BooleanField(default=False) require_user_conf = models.BooleanField(default=False)
require_user_auth_keys = models.BooleanField(default=False) require_user_keys = models.BooleanField(default=False)
def __str__(self): def __str__(self):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment