Uptake the changes to publish responses and add get_condition and get_measurement from id (#73)

* Upgrade to latest data.client dependency

* Fix mypy errors

* Fix nps style errors

* Update examples for new API

* Update all notebooks for the new datastore service API

* Add unit test coverage for get_measurement and get_condition.

* Remove call to get_measurement - not needed

---------

Co-authored-by: Joel Dixon <joel.dixon@emerson.com>

Author: dixonjoel

examples/notebooks/custom-metadata/custom_metadata.ipynb

@@ -141,7 +141,7 @@
         "\n",
         "step = Step(name=\"Initial step\", test_result_id=test_result_id)\n",
         "step_id = data_store_client.create_step(step)\n",
-        "published_measurement = data_store_client.publish_measurement(\n",
+        "data_store_client.publish_measurement(\n",
         "    name=\"scope reading\",\n",
         "    value=waveform,\n",
         "    step_id=step_id,\n",

examples/notebooks/overview/publish_measurement.ipynb

@@ -223,13 +223,12 @@
     ")\n",
     "step = Step(name=\"Initial step\", test_result_id=test_result_id)\n",
     "step_id = data_store_client.create_step(step)\n",
-    "published_measurement = data_store_client.publish_measurement(\n",
+    "published_measurement_id = data_store_client.publish_measurement(\n",
     "    name=name,\n",
     "    value=waveform,\n",
     "    step_id=step_id,\n",
     ")\n",
-    "\n",
-    "print(f\"The published measurement id is {published_measurement.id}\")"
+    "print(f\"The published measurement id is {published_measurement_id}\")"
    ]
   },
   {
@@ -251,7 +250,7 @@
    "source": [
     "from nitypes.waveform import AnalogWaveform\n",
     "\n",
-    "published_measurements = data_store_client.query_measurements(odata_query=f\"$filter=id eq {published_measurement.id}\")\n",
+    "published_measurements = data_store_client.query_measurements(odata_query=f\"$filter=id eq {published_measurement_id}\")\n",
     "found_measurement = next(iter(published_measurements), None)\n",
     "\n",
     "if found_measurement is not None:\n",

examples/overview/poetry.lock

@@ -41,9 +41,6 @@ requires-poetry = '>=2.1,<3.0'
 [tool.poetry.dependencies]
 python = "^3.10"
 protobuf = {version=">=4.21"}
-ni-datamonikers-v1-client = { version = ">=0.1.0.dev1", allow-prereleases = true }
-ni-measurements-data-v1-client = { version = ">=0.2.0.dev2", allow-prereleases = true }
-ni-measurements-metadata-v1-client = { version = ">=0.2.0.dev2", allow-prereleases = true }
 ni-protobuf-types = { version = ">=1.0.1.dev0", allow-prereleases = true }
 hightime = { version = ">=0.3.0.dev0", allow-prereleases = true }
 grpcio-tools = [

examples/overview/pyproject.toml

@@ -77,16 +77,17 @@ def publish_data() -> str:
         # Publish the test step with the waveform data
         step = Step(name="Initial step", test_result_id=test_result_id)
         step_id = data_store_client.create_step(step)
-        published_measurement = data_store_client.publish_measurement(
+        published_measurement_id = data_store_client.publish_measurement(
             name=name,
             value=waveform,
             step_id=step_id,
         )
+        published_measurement = data_store_client.get_measurement(published_measurement_id)
         print(
             f"Published measurement: '{published_measurement.name}' with id {published_measurement.id}"
         )
 
-    return published_measurement.id
+    return published_measurement_id
 
 
 def query_data(published_measurement_id: str) -> None:

examples/overview/src/overview.py

@@ -38,7 +38,7 @@ requires-poetry = '>=2.1,<3.0'
 python = "^3.10"
 protobuf = {version=">=4.21"}
 ni-datamonikers-v1-client = { version = ">=0.1.0.dev1", allow-prereleases = true }
-ni-measurements-data-v1-client = { version = ">=0.2.0.dev2", allow-prereleases = true }
+ni-measurements-data-v1-client = { version = ">=0.2.0.dev4", allow-prereleases = true }
 ni-measurements-metadata-v1-client = { version = ">=0.2.0.dev2", allow-prereleases = true }
 ni-protobuf-types = { version = ">=1.0.1.dev0", allow-prereleases = true }
 hightime = { version = ">=0.3.0.dev0", allow-prereleases = true }