revert making python_named_parameters required in jobs.api.run_now (#429)

Author: nordp

databricks_cli/jobs/api.py

@@ -49,10 +49,10 @@ def reset_job(self, json, headers=None, version=None):
         return self.client.client.perform_query('POST', '/jobs/reset', data=json, headers=headers,
                                                 version=version)
 
-    def run_now(self, job_id, jar_params, notebook_params, python_params, python_named_params,
-                spark_submit_params, headers=None, version=None):
+    def run_now(self, job_id, jar_params, notebook_params, python_params, spark_submit_params,
+                python_named_params=None, headers=None, version=None):
         return self.client.run_now(job_id, jar_params, notebook_params, python_params,
-                                   python_named_params, spark_submit_params, headers=headers,
+                                   spark_submit_params, python_named_params, headers=headers,
                                    version=version)
 
     def _list_jobs_by_name(self, name, headers=None):

databricks_cli/jobs/cli.py

@@ -235,7 +235,7 @@ def run_now_cli(api_client, job_id, jar_params, notebook_params, python_params,
     spark_submit_params = json_loads(spark_submit_params) if spark_submit_params else None
     res = JobsApi(api_client).run_now(
         job_id, jar_params_json, notebook_params_json, python_params,
-        python_named_params, spark_submit_params, version=version)
+        spark_submit_params, python_named_params, version=version)
     click.echo(pretty_format(res))
 
 

databricks_cli/sdk/service.py

@@ -156,8 +156,8 @@ def list_jobs(self, job_type=None, expand_tasks=None, limit=None, offset=None, h
 
         return self.client.perform_query('GET', '/jobs/list', data=_data, headers=headers, version=version)
 
-    def run_now(self, job_id=None, jar_params=None, notebook_params=None, python_params=None, python_named_params=None,
-                spark_submit_params=None, headers=None, version=None):
+    def run_now(self, job_id=None, jar_params=None, notebook_params=None, python_params=None, spark_submit_params=None,
+                python_named_params=None, headers=None, version=None):
         _data = {}
         if job_id is not None:
             _data['job_id'] = job_id

tests/jobs/test_cli.py

@@ -227,9 +227,9 @@ def test_run_now_with_params(jobs_api_mock):
         assert jobs_api_mock.run_now.call_args[0][3] == json.loads(
             PYTHON_PARAMS)
         assert jobs_api_mock.run_now.call_args[0][4] == json.loads(
-            PYTHON_NAMED_PARAMS)
-        assert jobs_api_mock.run_now.call_args[0][5] == json.loads(
             SPARK_SUBMIT_PARAMS)
+        assert jobs_api_mock.run_now.call_args[0][5] == json.loads(
+            PYTHON_NAMED_PARAMS)
         assert echo_mock.call_args[0][0] == pretty_format(RUN_NOW_RETURN)