🚑️ Fix parsing logic for named parameters in Jobs API 2.1 Asset-based launch (#771)

* fix docs

* finalize bugfix and add tests

* fix linting

Author: renardeinside

CHANGELOG.md

@@ -9,9 +9,16 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 [Please read through the Keep a Changelog (~5min)](https://keepachangelog.com/en/1.0.0/).
 
+## [0.8.13] - 2023-05-10
+
+### Fixed
+
+- Issue with passing `named_parameters` for an asset-based run in Jobs API 2.1 via CLI in `dbx launch`
+- Arguments used in docs for asset-based launch
+
 ## [0.8.12] - 2023-05-06
 
-## Fixed
+### Fixed
 
 - Explicitly pin the `requests` version to avoid issues with downstream libraries
 

dbx/__init__.py

@@ -1 +1 @@
-__version__ = "0.8.12"
+__version__ = "0.8.13"

dbx/models/workflow/v2dot1/_parameters.py

@@ -8,12 +8,13 @@
     StringArray,
     BaseParametersMixin,
     PipelineTaskParametersPayload,
+    NamedParametersMixin,
 )
 
 
 class FlexibleParametersMixin(ParametersMixin):
     parameters: Optional[Union[ParamPair, StringArray]]
 
 
-class PayloadElement(FlexibleParametersMixin, BaseParametersMixin, PipelineTaskParametersPayload):
+class PayloadElement(FlexibleParametersMixin, BaseParametersMixin, PipelineTaskParametersPayload, NamedParametersMixin):
     task_key: str

docs/guides/general/passing_parameters.md

@@ -70,8 +70,8 @@ All parameters should be provided in a form of a JSON-compatible payload (see ex
 
     Examples for Jobs API 2.0:
     ```bash
-    dbx launch <workflow_name> --assets-only --parameters='{"base_parameters": {"key1": "value1", "key2": "value2"}}' # for notebook_task
-    dbx launch <workflow_name> --assets-only --parameters='{"parameters": ["argument1", "argument2"]}' # for spark_jar_task, spark_python_task and spark_submit_task
+    dbx launch <workflow_name> --from-assets --parameters='{"base_parameters": {"key1": "value1", "key2": "value2"}}' # for notebook_task
+    dbx launch <workflow_name> --from-assets --parameters='{"parameters": ["argument1", "argument2"]}' # for spark_jar_task, spark_python_task and spark_submit_task
     ```
 
     For Jobs API 2.1, the payload format should be compliant with the [JobsRunSubmit](https://docs.databricks.com/dev-tools/api/latest/jobs.html#operation/JobsRunsSubmit).
@@ -81,27 +81,27 @@ All parameters should be provided in a form of a JSON-compatible payload (see ex
 
     ```bash
     # notebook_task
-    dbx launch <workflow_name> --assets-only <workflow_name> --parameters='[
+    dbx launch <workflow_name> --from-assets <workflow_name> --parameters='[
         {"task_key": "some", "base_parameters": {"a": 1, "b": 2}}
     ]'
 
     # spark_python_task, python_wheel_task, spark_jar_task, spark_submit_task, python_wheel_task
-    dbx launch <workflow_name> --assets-only <workflow_name> --parameters='[
+    dbx launch <workflow_name> --from-assets <workflow_name> --parameters='[
         {"task_key": "some", "parameters": ["a", "b"]}
     ]'
 
     # python_wheel_task
-    dbx launch <workflow_name> --assets-only <workflow_name> --parameters='[
+    dbx launch <workflow_name> --from-assets <workflow_name> --parameters='[
         {"task_key": "some", "named_parameters": {"a": 1, "b": 2}}
     ]'
 
     # pipeline_task
-    dbx launch <workflow_name> --assets-only <workflow_name> --parameters='[
+    dbx launch <workflow_name> --from-assets <workflow_name> --parameters='[
         {"task_key": "some", "full_refresh": true}
     ]'
 
     # sql_task
-    dbx launch <workflow_name> --assets-only <workflow_name> --parameters='[
+    dbx launch <workflow_name> --from-assets <workflow_name> --parameters='[
         {"task_key": "some", "parameters": {"key1": "value2"}}
     ]'
     ```

tests/unit/models/test_parameters.py

@@ -66,3 +66,11 @@ def test_assert_based_v2dot0_not_unique():
 def test_assert_based_v2dot1_good(param_raw_payload):
     parsed = V2dot1AssetBasedRunPayload.from_string(param_raw_payload)
     assert parsed.elements is not None
+
+
+def test_asset_based_v2dot1_sample():
+    payload = """[
+    {"task_key": "main", "named_parameters": {"a": 1, "b": 2}}
+    ]"""
+    parsed = V2dot1AssetBasedRunPayload.from_string(payload)
+    assert parsed.elements[0].named_parameters == {"a": 1, "b": 2}