diff options
| -rw-r--r-- | savannaclient/api/job_executions.py | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/savannaclient/api/job_executions.py b/savannaclient/api/job_executions.py index 80436e6..b1a7065 100644 --- a/savannaclient/api/job_executions.py +++ b/savannaclient/api/job_executions.py @@ -13,6 +13,7 @@ # See the License for the specific language governing permissions and # limitations under the License. +import copy from savannaclient.api import base @@ -32,13 +33,16 @@ class JobExecutionsManager(base.ResourceManager): def delete(self, obj_id): self._delete('/job-executions/%s' % obj_id) - def create(self, job_id, cluster_id, input_id, output_id, configs): + def create(self, job_id, cluster_id, input_id, output_id, configs, + job_exec_data={}): url = "/jobs/%s/execute" % job_id - data = { - "input_id": input_id, - "output_id": output_id, - "cluster_id": cluster_id, - "job_configs": configs - } + data = copy.copy(job_exec_data) + data.update( + { + "input_id": input_id, + "output_id": output_id, + "cluster_id": cluster_id, + "job_configs": configs + }) return self._create(url, data, 'job_execution') |