diff --git a/saharaclient/api/jobs.py b/saharaclient/api/jobs.py index a301ebcb..0e5bbecf 100644 --- a/saharaclient/api/jobs.py +++ b/saharaclient/api/jobs.py @@ -23,7 +23,8 @@ class Job(base.Resource): class JobsManager(base.ResourceManager): resource_class = Job - def create(self, name, type, mains, libs, description, interface=None): + def create(self, name, type, mains, libs, description, interface=None, + is_public=None, is_protected=None): data = { 'name': name, 'type': type, @@ -32,8 +33,8 @@ class JobsManager(base.ResourceManager): 'libs': libs, } - if interface: - data['interface'] = interface + self._copy_if_defined(data, interface=interface, is_public=is_public, + is_protected=is_protected) return self._create('/jobs', data, 'job') diff --git a/saharaclient/tests/unit/test_jobs.py b/saharaclient/tests/unit/test_jobs.py index 9aae93a9..39acb7c4 100644 --- a/saharaclient/tests/unit/test_jobs.py +++ b/saharaclient/tests/unit/test_jobs.py @@ -24,7 +24,9 @@ class JobTest(base.BaseTestCase): 'type': 'pig', 'mains': ['job_binary_id'], 'libs': [], - 'description': 'descr' + 'description': 'descr', + 'is_public': True, + 'is_protected': False } def test_create_job(self):