def METHOD_NAME(self):
    def my_pipeline():
        item_name = "test-item"
        json_spec = """
        {
            "content": "cHJpbnQoImhlbGxvLCB3b3JsZCIpCgoK",
            "path": "/Users/user@foo.com/ScalaExampleNotebook",
            "language": "SCALA",
            "format": "SOURCE"
        }
        """
        expected_spec = {
            "content": "cHJpbnQoImhlbGxvLCB3b3JsZCIpCgoK",
            "path": "/Users/user@foo.com/ScalaExampleNotebook",
            "language": "SCALA",
            "format": "SOURCE"
        }
        res = ImportWorkspaceItemOp.from_json_spec(
            name="importworkspaceitem",
            item_name=item_name,
            json_spec=json_spec
        )
        self.assert_res(res, expected_spec)
    kfp.compiler.Compiler()._create_workflow(my_pipeline)